package com.sg.service.biz.app.impl;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import com.sg.common.util.CommonFunctionHelper;
import com.sg.common.util.RedisUtil;
import com.sg.dto.biz.app.req.*;
import com.sg.dto.biz.app.res.*;
import com.sg.service.base.app.MOmsEvaBatchRelatedSetService;
import com.sg.service.base.app.MOmsEvaluationObjectTargetCycleService;
import com.sg.service.base.app.MOmsVirtualOrgMemberService;
import com.sg.service.biz.app.MessageService;
import com.sg.common.exception.Assert;
import com.wicket.okrcomponent.integration.CommunicationService;
import com.wicket.okrcomponent.integration.InterfaceModeService;
import com.wicket.okrcomponent.integration.MessageService;
import com.wicket.okrcomponent.integration.TemplateEngineService;
import com.wicket.okrcomponent.integration.dto.*;
import com.wicket.okrframework.integration.InductionRecordService;
import com.wicket.okrframework.integration.MessageService;
import com.wicket.okrframework.integration.OrgService;
import com.wicket.okrframework.integration.dto.*;
import org.apache.skywalking.apm.toolkit.trace.Tag;
import org.apache.skywalking.apm.toolkit.trace.Tags;
import org.apache.skywalking.apm.toolkit.trace.Trace;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.stream.Collectors;

/**
 * @author ：
 * @version 1.0
 * @date ：
 */
@Service
public class CommunicationServiceImpl
        implements com.wicket.okrapp.biz.service.CommunicationService {

    @Resource
    private RedisUtil redisUtil;
    //@Resource
    //private MCustomFields4Service mCustomFields4Service;
//@Resource
    //private undefinedService undefinedService;
    @Resource
    private MOmsEvaBatchRelatedSetService mOmsEvaBatchRelatedSetService;
    @Resource
    private NbCommunication nbCommunication;
    @Resource
    private MOmsVirtualOrgMemberService mOmsVirtualOrgMemberService;
    @Resource
    private InterfaceModeService interfaceModeService;
    @Resource
    private MessageService fwCompMessageClient;
    @Resource
    private InductionRecordService inductionRecordService;
    @Resource
    private TemplateEngineService fwCompTemplateEngineClient;
    @Resource
    private MessageService messageService;
    @Resource
    private CommunicationService fwCompCommunicationClient;
    @Resource
    private MOmsEvaluationObjectTargetCycleService mOmsEvaluationObjectTargetCycleService;
    //@Resource
    //private MOmsMessageService mOmsMessageService;
    @Resource
    private MessageService messageService;
    @Resource
    private OrgService orgService;

    /**
     * D3-执行异步初始化单个评价模板位置消息数量(公共)[8361]
     * gen by moon at 1/26/2024, 5:09:59 AM
     */
    @Trace(operationName = "D3-执行异步初始化单个评价模板位置消息数量(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public ImplementAsynSingleEvaTempMsgLocQtyComRespDto implementAsynSingleEvaTempMsgLocQtyCom(ImplementAsynSingleEvaTempMsgLocQtyComReqDto reqDto) {


        //步骤0: M3执行第四接收字段（特殊方法） - implementFourthReceivingField
        //ModelCode: receptionService
        ImplementFourthReceivingFieldRespDto receptionServiceRes = null;
        ImplementFourthReceivingFieldReqDto receptionServiceReq = new ImplementFourthReceivingFieldReqDto();
        if (reqDto != null) {
            receptionServiceReq.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1509459_1
        }

        /*M3-接收入参字段[8259]  用于特殊方法接收上游入参。 */
        Assert.isNull(receptionServiceReq.getEvaluationTemplateId(), "D3-执行异步初始化单个评价模板位置消息数量(公共)-M3-接收入参字段-冗余评价模板ID不能为空", false);
        receptionServiceRes = nbCommunication.implementFourthReceivingField(receptionServiceReq);


//步骤1: M3执行第四接收字段（特殊方法） - implementFourthReceivingField
        //ModelCode: receptionService
        ImplementFourthReceivingFieldRespDto receptionServiceRes_1 = null;
        ImplementFourthReceivingFieldReqDto receptionServiceReq_1 = new ImplementFourthReceivingFieldReqDto();
        receptionServiceReq_1.setCreateInductionId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecInductionRecordId());//CURRENT_INDUCTIONID//sourceId:1509257_1
        receptionServiceReq_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1509258_1
        receptionServiceReq_1.setAppId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecAppId());//CURRENT_APPID//sourceId:1509259_1

        /*M3-约定当前就职记录等（用于推缓存）[8259]  用于特殊方法接收上游入参。 */
        Assert.isNull(receptionServiceReq_1.getCreateInductionId(), "D3-执行异步初始化单个评价模板位置消息数量(公共)-M3-约定当前就职记录等（用于推缓存）-创建人就职记录ID不能为空", false);
        Assert.isNull(receptionServiceReq_1.getSpaceId(), "D3-执行异步初始化单个评价模板位置消息数量(公共)-M3-约定当前就职记录等（用于推缓存）-创建于空间ID不能为空", false);
        Assert.isNull(receptionServiceReq_1.getAppId(), "D3-执行异步初始化单个评价模板位置消息数量(公共)-M3-约定当前就职记录等（用于推缓存）-创建于联盟应用ID不能为空", false);
        receptionServiceRes_1 = nbCommunication.implementFourthReceivingField(receptionServiceReq_1);


//步骤2: M3异步开始（特殊方法） - addAsynchronizationStart
        //ModelCode: asynchronizationStart
        ImplementFourthReceivingFieldRespDto finalReceptionServiceRes_ = receptionServiceRes_1;
        Callable<String> call = new Callable<String>() {

            @Override
            public String call() throws Exception {
                //执行方法

//步骤3: M3执行业务应用公共字段推送内存（特殊方法） - implementBizPublicFieldPushMemory
                //ModelCode: publicFieldCache
                ImplementBizPublicFieldPushMemoryRespDto publicFieldCacheRes = null;
                ImplementBizPublicFieldPushMemoryReqDto publicFieldCacheReq = new ImplementBizPublicFieldPushMemoryReqDto();
                if (finalReceptionServiceRes_ != null) {
                    publicFieldCacheReq.setCreateInductionId(finalReceptionServiceRes_.getCreateInductionId());//SimpleFieldAssign//sourceId:1509461_1
                    publicFieldCacheReq.setSpaceId(finalReceptionServiceRes_.getSpaceId());//SimpleFieldAssign//sourceId:1509462_1
                    publicFieldCacheReq.setAppId(finalReceptionServiceRes_.getAppId());//SimpleFieldAssign//sourceId:1509463_1
                }

                /*M3执行业务应用公共字段推送内存（特殊方法）[4520]  用于定时任务执行时，获取定时任务执行所需的公共信息，存入缓存，供定时任务中虚拟用况使用 */
                Assert.isNull(publicFieldCacheReq.getCreateInductionId(), "D3-执行异步初始化单个评价模板位置消息数量(公共)-M3执行业务应用公共字段推送内存（特殊方法）-创建人就职记录ID 不能为空", false);
                Assert.isNull(publicFieldCacheReq.getSpaceId(), "D3-执行异步初始化单个评价模板位置消息数量(公共)-M3执行业务应用公共字段推送内存（特殊方法）-创建于空间ID不能为空", false);
                Assert.isNull(publicFieldCacheReq.getAppId(), "D3-执行异步初始化单个评价模板位置消息数量(公共)-M3执行业务应用公共字段推送内存（特殊方法）-创建于联盟应用ID不能为空", false);
                publicFieldCacheRes = nbCommunication.implementBizPublicFieldPushMemory(publicFieldCacheReq);


//步骤4: D3-执行初始化单个评价模板位置消息数量(公共) - implementSingleEvaTempMsgLocQtyCom
                ImplementSingleEvaTempMsgLocQtyComRespDto implementSingleEvaTempMsgLocQtyComRespDto = null;
                ImplementSingleEvaTempMsgLocQtyComReqDto implementSingleEvaTempMsgLocQtyComReqDto = new ImplementSingleEvaTempMsgLocQtyComReqDto();
                if (reqDto != null) {
                    implementSingleEvaTempMsgLocQtyComReqDto.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1509067_1
                }
                if (finalReceptionServiceRes_ != null) {
                    implementSingleEvaTempMsgLocQtyComReqDto.setSpaceId(finalReceptionServiceRes_.getSpaceId());//SimpleFieldAssign//sourceId:1509068_1
                }

                /*D3-执行初始化单个评价模板位置消息数量(公共)[8356]   */
                Assert.isNull(implementSingleEvaTempMsgLocQtyComReqDto.getEvaluationTemplateId(), "D3-执行异步初始化单个评价模板位置消息数量(公共)-D3-执行初始化单个评价模板位置消息数量(公共)-冗余评价模板ID不能为空", false);
                Assert.isNull(implementSingleEvaTempMsgLocQtyComReqDto.getSpaceId(), "D3-执行异步初始化单个评价模板位置消息数量(公共)-D3-执行初始化单个评价模板位置消息数量(公共)-创建于空间ID不能为空", false);
                implementSingleEvaTempMsgLocQtyComRespDto = implementSingleEvaTempMsgLocQtyCom(implementSingleEvaTempMsgLocQtyComReqDto)/*vcase invoke 同服务,同domain*/;


//步骤5: M3异步结束（特殊方法） - addAsynchronizationEnd
                //ModelCode: asynchronizationEnd
                return "";
            }
        };
        CommonFunctionHelper.asynExcute(call);

        ImplementAsynSingleEvaTempMsgLocQtyComRespDto retData = new ImplementAsynSingleEvaTempMsgLocQtyComRespDto();


        return retData;
    }

    /**
     * D3-执行初始化单个评价模板位置消息数量(公共)[8356]
     * gen by moon at 1/26/2024, 5:02:52 PM
     */
    @Trace(operationName = "D3-执行初始化单个评价模板位置消息数量(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public ImplementSingleEvaTempMsgLocQtyComRespDto implementSingleEvaTempMsgLocQtyCom(ImplementSingleEvaTempMsgLocQtyComReqDto reqDto) {


        //virtualUsage 3-6-02查评价模板下所有小圈子的负责人列表  60229
        List<OmsVirtualOrgMember> listOmsVirtualOrgMember = new ArrayList<>();
        QueryMsgSendVirtualOrgMemberListReq queryMsgSendVirtualOrgMemberListReq = new QueryMsgSendVirtualOrgMemberListReq();
        queryMsgSendVirtualOrgMemberListReq.setUseScene("TARGET_PLAN_SCENE");//sourceId:1507922_1_60229
        queryMsgSendVirtualOrgMemberListReq.setIsPersonCharge("TRUE");//sourceId:1509559_1_60229
        queryMsgSendVirtualOrgMemberListReq.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1507923_1_60229
        if (reqDto != null) {
            queryMsgSendVirtualOrgMemberListReq.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1507928_1_60229
            queryMsgSendVirtualOrgMemberListReq.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1507924_1_60229
        }

        /*3-6-02查评价模板下所有小圈子的负责人列表[8224]   */
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq.getUseScene(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的负责人列表-虚拟组织使用场景不能为空", false);
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq.getIsPersonCharge(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的负责人列表-是否负责人不能为空", false);
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq.getSubjectLifeCycle(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的负责人列表-主体生命周期不能为空", false);
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq.getEvaluationTemplateId(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的负责人列表-归属对象ID不能为空", false);
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq.getSpaceId(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的负责人列表-创建于空间ID不能为空", false);
        listOmsVirtualOrgMember = mOmsVirtualOrgMemberService.queryMsgSendVirtualOrgMemberList(queryMsgSendVirtualOrgMemberListReq)/*vcase invoke 本地 method 方法调用;*/;


//virtualUsage D2执行多字段数据集记录去重(公共)  60230
        ImplementManyFieldsDataSetDuplicateRemovalComRespDto implementManyFieldsDataSetDuplicateRemovalComRespDto = null;
        if (listOmsVirtualOrgMember != null && !CollectionUtil.isEmpty(listOmsVirtualOrgMember) && listOmsVirtualOrgMember.size() > 0) {
            ImplementManyFieldsDataSetDuplicateRemovalComReqDto implementManyFieldsDataSetDuplicateRemovalComReqDto = new ImplementManyFieldsDataSetDuplicateRemovalComReqDto();
            if (listOmsVirtualOrgMember != null && !CollectionUtil.isEmpty(listOmsVirtualOrgMember) && listOmsVirtualOrgMember != null && !CollectionUtil.isEmpty(listOmsVirtualOrgMember)) {
                implementManyFieldsDataSetDuplicateRemovalComReqDto.setDataSetDuplicateRemovalList(//objList-to-objLists
                        listOmsVirtualOrgMember.stream().map(item -> {
                            DataSetDuplicateRemovalDto elm = new DataSetDuplicateRemovalDto();
                            elm.setCommPrimaryKey(item.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:296500_2_60230
                            elm.setCustomField1(item.getUserId());//SimpleFieldAssign//sourceId:296501_2_60230
                            return elm;
                        }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1507956_1_60230
            }

            /*D2执行多字段数据集记录去重(公共)[7323]   */

            implementManyFieldsDataSetDuplicateRemovalComRespDto = interfaceModeService.implementManyFieldsDataSetDuplicateRemovalCom(implementManyFieldsDataSetDuplicateRemovalComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


        }
        if ((implementManyFieldsDataSetDuplicateRemovalComRespDto != null && implementManyFieldsDataSetDuplicateRemovalComRespDto.getDataSetDuplicateRemovalList() != null && implementManyFieldsDataSetDuplicateRemovalComRespDto.getDataSetDuplicateRemovalList().size() > 0)) {
            //if(D2将所有小圈子的负责人及主管按身份人员去重(公共).数据集记录去重列表数据集条数 大于 0)  60231

//ModelCode: receptionService
            ImplementFourthReceivingFieldRespDto receptionServiceRes = null;
            if (implementManyFieldsDataSetDuplicateRemovalComRespDto != null) {
                ImplementFourthReceivingFieldReqDto receptionServiceReq = new ImplementFourthReceivingFieldReqDto();
                if (implementManyFieldsDataSetDuplicateRemovalComRespDto != null && implementManyFieldsDataSetDuplicateRemovalComRespDto.getDataSetDuplicateRemovalList() != null && !CollectionUtil.isEmpty(implementManyFieldsDataSetDuplicateRemovalComRespDto.getDataSetDuplicateRemovalList())) {
                    receptionServiceReq.setVirtualOrgMemberList(//objList-to-objLists
                            implementManyFieldsDataSetDuplicateRemovalComRespDto.getDataSetDuplicateRemovalList().stream().map(item -> {
                                VirtualOrgMemberDto elm = new VirtualOrgMemberDto();
                                if (item != null) {
                                    elm.setOriginalRoleMemberId(item.getCommPrimaryKey());//SimpleFieldAssign//sourceId:296527_2_60232
                                    elm.setUserId(item.getCustomField1());//SimpleFieldAssign//sourceId:296528_2_60232
                                }
                                return elm;
                            }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1508297_1_60232
                }

                /*M3用于接收数据集入参[8259]  用于特殊方法接收上游入参。 */

                receptionServiceRes = nbCommunication.implementFourthReceivingField(receptionServiceReq);


            }
//ModelCode: circulationCollections
            for (VirtualOrgMemberDto circulationCollectionsRes : receptionServiceRes.getVirtualOrgMemberList()) {

                ImplementInitSingleEvaTempMsgLocQtyComRespDto implementInitSingleEvaTempMsgLocQtyComRespDto = null;
                ImplementInitSingleEvaTempMsgLocQtyComReqDto implementInitSingleEvaTempMsgLocQtyComReqDto = new ImplementInitSingleEvaTempMsgLocQtyComReqDto();
                implementInitSingleEvaTempMsgLocQtyComReqDto.setReportTaskEvaRoom("MY_REPORT_TASK");//sourceId:1508306_1_60271
                if (circulationCollectionsRes != null) {
                    implementInitSingleEvaTempMsgLocQtyComReqDto.setOriginalRoleMemberId(circulationCollectionsRes.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1508307_1_60271
                    implementInitSingleEvaTempMsgLocQtyComReqDto.setUserId(circulationCollectionsRes.getUserId());//SimpleFieldAssign//sourceId:1508308_1_60271
                }
                if (reqDto != null) {
                    implementInitSingleEvaTempMsgLocQtyComReqDto.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1508309_1_60271
                    implementInitSingleEvaTempMsgLocQtyComReqDto.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1508310_1_60271
                }

                /*D2-初始化单个评价模板位置消息数量（我汇报的）[8343]   */
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto.getReportTaskEvaRoom(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我汇报的）-汇报任务评价房间不能为空", false);
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto.getOriginalRoleMemberId(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我汇报的）-身份人员ID不能为空", false);
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto.getUserId(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我汇报的）-账号不能为空", false);
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto.getEvaluationTemplateId(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我汇报的）-冗余评价模板ID不能为空", false);
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto.getSpaceId(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我汇报的）-创建于空间ID不能为空", false);
                implementInitSingleEvaTempMsgLocQtyComRespDto = fwCompMessageClient.implementInitSingleEvaTempMsgLocQtyCom(implementInitSingleEvaTempMsgLocQtyComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


//ModelCode: circulationEnd
            }

        }
//virtualUsage 3-6-02查评价模板下所有小圈子的主管列表  60270
        List<OmsVirtualOrgMember> listOmsVirtualOrgMember_2 = new ArrayList<>();
        QueryMsgSendVirtualOrgMemberListReq queryMsgSendVirtualOrgMemberListReq_1 = new QueryMsgSendVirtualOrgMemberListReq();
        queryMsgSendVirtualOrgMemberListReq_1.setUseScene("TARGET_PLAN_SCENE");//sourceId:1509550_1_60270
        queryMsgSendVirtualOrgMemberListReq_1.setRoleCode("DIRECTOR");//CUSTOM_CONVENTION//sourceId:1509560_1_60270
        queryMsgSendVirtualOrgMemberListReq_1.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1509551_1_60270
        if (reqDto != null) {
            queryMsgSendVirtualOrgMemberListReq_1.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1509556_1_60270
            queryMsgSendVirtualOrgMemberListReq_1.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1509552_1_60270
        }

        /*3-6-02查评价模板下所有小圈子的主管列表[8224]   */
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq_1.getUseScene(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的主管列表-虚拟组织使用场景不能为空", false);
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq_1.getRoleCode(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的主管列表-角色标识不能为空", false);
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq_1.getSubjectLifeCycle(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的主管列表-主体生命周期不能为空", false);
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq_1.getEvaluationTemplateId(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的主管列表-归属对象ID不能为空", false);
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq_1.getSpaceId(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的主管列表-创建于空间ID不能为空", false);
        listOmsVirtualOrgMember_2 = mOmsVirtualOrgMemberService.queryMsgSendVirtualOrgMemberList(queryMsgSendVirtualOrgMemberListReq_1)/*vcase invoke 本地 method 方法调用;*/;


//virtualUsage D2执行多字段数据集记录去重(公共)  60272
        ImplementManyFieldsDataSetDuplicateRemovalComRespDto implementManyFieldsDataSetDuplicateRemovalComRespDto_2 = null;
        if (listOmsVirtualOrgMember_2 != null && !CollectionUtil.isEmpty(listOmsVirtualOrgMember_2) && listOmsVirtualOrgMember_2.size() > 0) {
            ImplementManyFieldsDataSetDuplicateRemovalComReqDto implementManyFieldsDataSetDuplicateRemovalComReqDto_1 = new ImplementManyFieldsDataSetDuplicateRemovalComReqDto();
            if (listOmsVirtualOrgMember_2 != null && !CollectionUtil.isEmpty(listOmsVirtualOrgMember_2) && listOmsVirtualOrgMember_2 != null && !CollectionUtil.isEmpty(listOmsVirtualOrgMember_2)) {
                implementManyFieldsDataSetDuplicateRemovalComReqDto_1.setDataSetDuplicateRemovalList(//objList-to-objLists
                        listOmsVirtualOrgMember_2.stream().map(item -> {
                            DataSetDuplicateRemovalDto elm = new DataSetDuplicateRemovalDto();
                            elm.setCommPrimaryKey(item.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:296500_2_60272
                            elm.setCustomField1(item.getUserId());//SimpleFieldAssign//sourceId:296501_2_60272
                            return elm;
                        }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1507956_1_60272
            }

            /*D2执行多字段数据集记录去重(公共)[7323]   */

            implementManyFieldsDataSetDuplicateRemovalComRespDto_2 = interfaceModeService.implementManyFieldsDataSetDuplicateRemovalCom(implementManyFieldsDataSetDuplicateRemovalComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;


        }
        if ((implementManyFieldsDataSetDuplicateRemovalComRespDto_2 != null && implementManyFieldsDataSetDuplicateRemovalComRespDto_2.getDataSetDuplicateRemovalList() != null && implementManyFieldsDataSetDuplicateRemovalComRespDto_2.getDataSetDuplicateRemovalList().size() > 0)) {
            //if(D2将所有小圈子的主管按身份人员去重(公共).数据集记录去重列表数据集条数 大于 0)  60273

//ModelCode: receptionService
            ImplementFourthReceivingFieldRespDto receptionServiceRes_2 = null;
            if (implementManyFieldsDataSetDuplicateRemovalComRespDto_2 != null) {
                ImplementFourthReceivingFieldReqDto receptionServiceReq_1 = new ImplementFourthReceivingFieldReqDto();
                if (implementManyFieldsDataSetDuplicateRemovalComRespDto_2 != null && implementManyFieldsDataSetDuplicateRemovalComRespDto_2.getDataSetDuplicateRemovalList() != null && !CollectionUtil.isEmpty(implementManyFieldsDataSetDuplicateRemovalComRespDto_2.getDataSetDuplicateRemovalList())) {
                    receptionServiceReq_1.setVirtualOrgMemberList(//objList-to-objLists
                            implementManyFieldsDataSetDuplicateRemovalComRespDto_2.getDataSetDuplicateRemovalList().stream().map(item -> {
                                VirtualOrgMemberDto elm = new VirtualOrgMemberDto();
                                if (item != null) {
                                    elm.setOriginalRoleMemberId(item.getCommPrimaryKey());//SimpleFieldAssign//sourceId:296527_2_60274
                                    elm.setUserId(item.getCustomField1());//SimpleFieldAssign//sourceId:296528_2_60274
                                }
                                return elm;
                            }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1508297_1_60274
                }

                /*M3用于接收数据集入参[8259]  用于特殊方法接收上游入参。 */

                receptionServiceRes_2 = nbCommunication.implementFourthReceivingField(receptionServiceReq_1);


            }
//ModelCode: circulationCollections
            for (VirtualOrgMemberDto circulationCollectionsRes_2 : receptionServiceRes_2.getVirtualOrgMemberList()) {

                ImplementInitSingleEvaTempMsgLocQtyComRespDto implementInitSingleEvaTempMsgLocQtyComRespDto_1 = null;
                ImplementInitSingleEvaTempMsgLocQtyComReqDto implementInitSingleEvaTempMsgLocQtyComReqDto_1 = new ImplementInitSingleEvaTempMsgLocQtyComReqDto();
                implementInitSingleEvaTempMsgLocQtyComReqDto_1.setReportTaskEvaRoom("TASK_REPORT_TO_ME");//sourceId:1508311_1_60276
                if (circulationCollectionsRes_2 != null) {
                    implementInitSingleEvaTempMsgLocQtyComReqDto_1.setOriginalRoleMemberId(circulationCollectionsRes_2.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1508312_1_60276
                    implementInitSingleEvaTempMsgLocQtyComReqDto_1.setUserId(circulationCollectionsRes_2.getUserId());//SimpleFieldAssign//sourceId:1508313_1_60276
                }
                if (reqDto != null) {
                    implementInitSingleEvaTempMsgLocQtyComReqDto_1.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1508314_1_60276
                    implementInitSingleEvaTempMsgLocQtyComReqDto_1.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1508315_1_60276
                }

                /*D2-初始化单个评价模板位置消息数量（汇报给我的）[8343]   */
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_1.getReportTaskEvaRoom(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（汇报给我的）-汇报任务评价房间不能为空", false);
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_1.getOriginalRoleMemberId(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（汇报给我的）-身份人员ID不能为空", false);
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_1.getUserId(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（汇报给我的）-账号不能为空", false);
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_1.getEvaluationTemplateId(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（汇报给我的）-冗余评价模板ID不能为空", false);
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_1.getSpaceId(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（汇报给我的）-创建于空间ID不能为空", false);
                implementInitSingleEvaTempMsgLocQtyComRespDto_1 = fwCompMessageClient.implementInitSingleEvaTempMsgLocQtyCom(implementInitSingleEvaTempMsgLocQtyComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;


//ModelCode: circulationEnd
            }

        }
//virtualUsage 3-6-02查评价模板下所有小圈子的相关人列表  60241
        List<OmsVirtualOrgMember> listOmsVirtualOrgMember_4 = new ArrayList<>();
        QueryMsgSendVirtualOrgMemberListReq queryMsgSendVirtualOrgMemberListReq_2 = new QueryMsgSendVirtualOrgMemberListReq();
        queryMsgSendVirtualOrgMemberListReq_2.setUseScene("TARGET_PLAN_SCENE");//sourceId:1508322_1_60241
        queryMsgSendVirtualOrgMemberListReq_2.setIsUpperLowerLevels("FALSE");//sourceId:1508327_1_60241
        queryMsgSendVirtualOrgMemberListReq_2.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1508323_1_60241
        if (reqDto != null) {
            queryMsgSendVirtualOrgMemberListReq_2.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1508328_1_60241
            queryMsgSendVirtualOrgMemberListReq_2.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1508324_1_60241
        }

        /*3-6-02查评价模板下所有小圈子的相关人列表[8224]   */
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq_2.getUseScene(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的相关人列表-虚拟组织使用场景不能为空", false);
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq_2.getIsUpperLowerLevels(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的相关人列表-是否上下级关系不能为空", false);
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq_2.getSubjectLifeCycle(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的相关人列表-主体生命周期不能为空", false);
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq_2.getEvaluationTemplateId(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的相关人列表-归属对象ID不能为空", false);
        Assert.isNull(queryMsgSendVirtualOrgMemberListReq_2.getSpaceId(), "D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的相关人列表-创建于空间ID不能为空", false);
        listOmsVirtualOrgMember_4 = mOmsVirtualOrgMemberService.queryMsgSendVirtualOrgMemberList(queryMsgSendVirtualOrgMemberListReq_2)/*vcase invoke 本地 method 方法调用;*/;


//virtualUsage D2执行多字段数据集记录去重(公共)  60242
        ImplementManyFieldsDataSetDuplicateRemovalComRespDto implementManyFieldsDataSetDuplicateRemovalComRespDto_3 = null;
        if (listOmsVirtualOrgMember_4 != null && !CollectionUtil.isEmpty(listOmsVirtualOrgMember_4) && listOmsVirtualOrgMember_4.size() > 0) {
            ImplementManyFieldsDataSetDuplicateRemovalComReqDto implementManyFieldsDataSetDuplicateRemovalComReqDto_2 = new ImplementManyFieldsDataSetDuplicateRemovalComReqDto();
            if (listOmsVirtualOrgMember_4 != null && !CollectionUtil.isEmpty(listOmsVirtualOrgMember_4) && listOmsVirtualOrgMember_4 != null && !CollectionUtil.isEmpty(listOmsVirtualOrgMember_4)) {
                implementManyFieldsDataSetDuplicateRemovalComReqDto_2.setDataSetDuplicateRemovalList(//objList-to-objLists
                        listOmsVirtualOrgMember_4.stream().map(item -> {
                            DataSetDuplicateRemovalDto elm = new DataSetDuplicateRemovalDto();
                            elm.setCommPrimaryKey(item.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:296500_2_60242
                            elm.setCustomField1(item.getUserId());//SimpleFieldAssign//sourceId:296501_2_60242
                            return elm;
                        }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1507956_1_60242
            }

            /*D2执行多字段数据集记录去重(公共)[7323]   */

            implementManyFieldsDataSetDuplicateRemovalComRespDto_3 = interfaceModeService.implementManyFieldsDataSetDuplicateRemovalCom(implementManyFieldsDataSetDuplicateRemovalComReqDto_2).getData()/*vcase invoke 跨dubbo调用;*/;


        }
        if ((implementManyFieldsDataSetDuplicateRemovalComRespDto_3 != null && implementManyFieldsDataSetDuplicateRemovalComRespDto_3.getDataSetDuplicateRemovalList() != null && implementManyFieldsDataSetDuplicateRemovalComRespDto_3.getDataSetDuplicateRemovalList().size() > 0)) {
            //if(D2将所有小圈子的相关人按身份人员去重(公共).数据集记录去重列表数据集条数 大于 0)  60243

//ModelCode: receptionService
            ImplementFourthReceivingFieldRespDto receptionServiceRes_3 = null;
            if (implementManyFieldsDataSetDuplicateRemovalComRespDto_3 != null) {
                ImplementFourthReceivingFieldReqDto receptionServiceReq_2 = new ImplementFourthReceivingFieldReqDto();
                if (implementManyFieldsDataSetDuplicateRemovalComRespDto_3 != null && implementManyFieldsDataSetDuplicateRemovalComRespDto_3.getDataSetDuplicateRemovalList() != null && !CollectionUtil.isEmpty(implementManyFieldsDataSetDuplicateRemovalComRespDto_3.getDataSetDuplicateRemovalList())) {
                    receptionServiceReq_2.setVirtualOrgMemberList(//objList-to-objLists
                            implementManyFieldsDataSetDuplicateRemovalComRespDto_3.getDataSetDuplicateRemovalList().stream().map(item -> {
                                VirtualOrgMemberDto elm = new VirtualOrgMemberDto();
                                if (item != null) {
                                    elm.setOriginalRoleMemberId(item.getCommPrimaryKey());//SimpleFieldAssign//sourceId:296527_2_60244
                                    elm.setUserId(item.getCustomField1());//SimpleFieldAssign//sourceId:296528_2_60244
                                }
                                return elm;
                            }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1508297_1_60244
                }

                /*M3用于接收数据集入参[8259]  用于特殊方法接收上游入参。 */

                receptionServiceRes_3 = nbCommunication.implementFourthReceivingField(receptionServiceReq_2);


            }
//ModelCode: circulationCollections
            for (VirtualOrgMemberDto circulationCollectionsRes_3 : receptionServiceRes_3.getVirtualOrgMemberList()) {

                ImplementInitSingleEvaTempMsgLocQtyComRespDto implementInitSingleEvaTempMsgLocQtyComRespDto_2 = null;
                ImplementInitSingleEvaTempMsgLocQtyComReqDto implementInitSingleEvaTempMsgLocQtyComReqDto_2 = new ImplementInitSingleEvaTempMsgLocQtyComReqDto();
                implementInitSingleEvaTempMsgLocQtyComReqDto_2.setReportTaskEvaRoom("TASK_RELATED_TO_ME");//sourceId:1508316_1_60247
                if (circulationCollectionsRes_3 != null) {
                    implementInitSingleEvaTempMsgLocQtyComReqDto_2.setOriginalRoleMemberId(circulationCollectionsRes_3.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1508317_1_60247
                    implementInitSingleEvaTempMsgLocQtyComReqDto_2.setUserId(circulationCollectionsRes_3.getUserId());//SimpleFieldAssign//sourceId:1508318_1_60247
                }
                if (reqDto != null) {
                    implementInitSingleEvaTempMsgLocQtyComReqDto_2.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1508319_1_60247
                    implementInitSingleEvaTempMsgLocQtyComReqDto_2.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1508320_1_60247
                }

                /*D2-初始化单个评价模板位置消息数量（我相关的）[8343]   */
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_2.getReportTaskEvaRoom(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我相关的）-汇报任务评价房间不能为空", false);
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_2.getOriginalRoleMemberId(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我相关的）-身份人员ID不能为空", false);
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_2.getUserId(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我相关的）-账号不能为空", false);
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_2.getEvaluationTemplateId(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我相关的）-冗余评价模板ID不能为空", false);
                Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_2.getSpaceId(), "D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我相关的）-创建于空间ID不能为空", false);
                implementInitSingleEvaTempMsgLocQtyComRespDto_2 = fwCompMessageClient.implementInitSingleEvaTempMsgLocQtyCom(implementInitSingleEvaTempMsgLocQtyComReqDto_2).getData()/*vcase invoke 跨dubbo调用;*/;


//ModelCode: circulationEnd
            }

        }
        ImplementSingleEvaTempMsgLocQtyComRespDto retData = new ImplementSingleEvaTempMsgLocQtyComRespDto();


        return retData;
    }

    /**
     * D3执行分享到部门大家想法(公共)[8358]
     * gen by moon at 2/23/2024, 2:19:40 AM
     */
    @Trace(operationName = "D3执行分享到部门大家想法(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public ImplementShareEveryoneIdeasDeptComRespDto implementShareEveryoneIdeasDeptCom(ImplementShareEveryoneIdeasDeptComReqDto reqDto) {


        //virtualUsage D2-查询当前分享的消息（想法或笔记）  60268
        QueryMessageDetailComRespDto queryMessageDetailComRespDto = null;
        QueryMessageDetailComReqDto queryMessageDetailComReqDto = new QueryMessageDetailComReqDto();
        queryMessageDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1509524_1_60268
        if (reqDto != null) {
            queryMessageDetailComReqDto.setMessageId(reqDto.getMessageId());//SimpleFieldAssign//sourceId:1509523_1_60268
        }

        /*D2-查询当前分享的消息（想法或笔记）[7526]   */
        Assert.isNull(queryMessageDetailComReqDto.getMessageId(), "D3执行分享到部门大家想法(公共)-D2-查询当前分享的消息（想法或笔记）-消息ID不能为空", false);
        Assert.isNull(queryMessageDetailComReqDto.getSpaceId(), "D3执行分享到部门大家想法(公共)-D2-查询当前分享的消息（想法或笔记）-创建于空间ID不能为空", false);
        queryMessageDetailComRespDto = fwCompMessageClient.queryMessageDetailCom(queryMessageDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
        Assert.isTrue(queryMessageDetailComRespDto == null || queryMessageDetailComRespDto.getMessageId() == null, "找不到数据，系统异常", false);


//virtualUsage D1-3查发送人头像、姓名、身份人员ID等（分享人）  60259
        QueryInductionRecordInfoDetailComRespDto queryInductionRecordInfoDetailComRespDto = null;
        QueryInductionRecordInfoDetailComReqDto queryInductionRecordInfoDetailComReqDto = new QueryInductionRecordInfoDetailComReqDto();
        queryInductionRecordInfoDetailComReqDto.setInductionRecordId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecInductionRecordId());//CURRENT_INDUCTIONID//sourceId:1508253_1_60259
        queryInductionRecordInfoDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1508261_1_60259

        /*D1-3查发送人头像、姓名、身份人员ID等（分享人）[715]   */
        Assert.isNull(queryInductionRecordInfoDetailComReqDto.getInductionRecordId(), "D3执行分享到部门大家想法(公共)-D1-3查发送人头像、姓名、身份人员ID等（分享人）-就职记录ID不能为空", false);
        Assert.isNull(queryInductionRecordInfoDetailComReqDto.getSpaceId(), "D3执行分享到部门大家想法(公共)-D1-3查发送人头像、姓名、身份人员ID等（分享人）-创建于空间ID不能为空", false);
        queryInductionRecordInfoDetailComRespDto = inductionRecordService.queryInductionRecordInfoDetailCom(queryInductionRecordInfoDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
        Assert.isTrue(queryInductionRecordInfoDetailComRespDto == null || queryInductionRecordInfoDetailComRespDto.getInductionRecordId() == null, "找不到数据，系统异常", false);


//virtualUsage D2生成“谁谁谁*邀请多人进入小岛  60260
        GenerateSemanticInstanceStoryComRespDto generateSemanticInstanceStoryComRespDto = null;
        if (queryInductionRecordInfoDetailComRespDto != null) {
            GenerateSemanticInstanceStoryComReqDto generateSemanticInstanceStoryComReqDto = new GenerateSemanticInstanceStoryComReqDto();
            generateSemanticInstanceStoryComReqDto.setTemplateSemanticEngineCode("CREATE_MULT_GROUP_DEFAULT_PROMPT_MESSAGE");//CUSTOM_CONVENTION//sourceId:1508271_1_60260
            generateSemanticInstanceStoryComReqDto.setFirstFieldName("idCardName");//CUSTOM_CONVENTION//sourceId:1508265_1_60260
            if (queryInductionRecordInfoDetailComRespDto != null) {
                generateSemanticInstanceStoryComReqDto.setFirstFieldValue(queryInductionRecordInfoDetailComRespDto.getIdCardName());//SimpleFieldAssign//sourceId:1508266_1_60260
            }

            /*D2生成“谁谁谁*邀请多人进入小岛[8234]   */
            Assert.isNull(generateSemanticInstanceStoryComReqDto.getTemplateSemanticEngineCode(), "D3执行分享到部门大家想法(公共)-D2生成“谁谁谁*邀请多人进入小岛-模板引擎标识不能为空", false);
            Assert.isNull(generateSemanticInstanceStoryComReqDto.getFirstFieldName(), "D3执行分享到部门大家想法(公共)-D2生成“谁谁谁*邀请多人进入小岛-第一个字段字段名不能为空", false);
            Assert.isNull(generateSemanticInstanceStoryComReqDto.getFirstFieldValue(), "D3执行分享到部门大家想法(公共)-D2生成“谁谁谁*邀请多人进入小岛-第一个字段字段值不能为空", false);
            generateSemanticInstanceStoryComRespDto = fwCompTemplateEngineClient.generateSemanticInstanceStoryCom(generateSemanticInstanceStoryComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


        }
//virtualUsage D2查询通道详情(公共)  60269
        QueryChannelDetailComRespDto queryChannelDetailComRespDto = null;
        QueryChannelDetailComReqDto queryChannelDetailComReqDto = new QueryChannelDetailComReqDto();
        queryChannelDetailComReqDto.setChannelTypeCode("DEPT_IDEA_GROUP");//sourceId:1509468_1_60269
        queryChannelDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1509470_1_60269
        if (reqDto != null) {
            queryChannelDetailComReqDto.setEntityId(reqDto.getDeptId());//SimpleFieldAssign//sourceId:1509469_1_60269
        }

        /*D2查询通道详情(公共)[7101]   */
        Assert.isNull(queryChannelDetailComReqDto.getChannelTypeCode(), "D3执行分享到部门大家想法(公共)-D2查询通道详情(公共)-通道类型编码不能为空", false);
        Assert.isNull(queryChannelDetailComReqDto.getEntityId(), "D3执行分享到部门大家想法(公共)-D2查询通道详情(公共)-归属主体内容ID不能为空", false);
        Assert.isNull(queryChannelDetailComReqDto.getSpaceId(), "D3执行分享到部门大家想法(公共)-D2查询通道详情(公共)-创建于空间ID不能为空", false);
        queryChannelDetailComRespDto = fwCompMessageClient.queryChannelDetailCom(queryChannelDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


        if ((queryChannelDetailComRespDto != null && queryChannelDetailComRespDto.getMessageChannelId() == null)) {
            //if(D2查询通道详情(公共).通道ID 值等于空 )  60254

            QueryDeptDetailComBorderRespDto queryDeptDetailComBorderRespDto = null;
            QueryDeptDetailComBorderReqDto queryDeptDetailComBorderReqDto = new QueryDeptDetailComBorderReqDto();
            queryDeptDetailComBorderReqDto.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1558527_1_61650
            if (reqDto != null) {
                queryDeptDetailComBorderReqDto.setDeptId(reqDto.getDeptId());//SimpleFieldAssign//sourceId:1558513_1_61650
            }

            /*D1-3查询部门详情(公共)(边界)[2691]   */
            Assert.isNull(queryDeptDetailComBorderReqDto.getDeptId(), "D3执行分享到部门大家想法(公共)-D1-3查询部门详情(公共)(边界)-部门ID不能为空", false);
            Assert.isNull(queryDeptDetailComBorderReqDto.getSubjectLifeCycle(), "D3执行分享到部门大家想法(公共)-D1-3查询部门详情(公共)(边界)-主体生命周期不能为空", false);
            queryDeptDetailComBorderRespDto = orgService.queryDeptDetailComBorder(queryDeptDetailComBorderReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
            Assert.isTrue(queryDeptDetailComBorderRespDto == null || queryDeptDetailComBorderRespDto.getDeptCode() == null, "找不到数据，系统异常", false);


            QuerySubordinateDeptTreeListComBorderRespDto querySubordinateDeptTreeListComBorderRespDto = null;
            if (queryDeptDetailComBorderRespDto != null) {
                QuerySubordinateDeptTreeListComBorderReqDto querySubordinateDeptTreeListComBorderReqDto = new QuerySubordinateDeptTreeListComBorderReqDto();
                querySubordinateDeptTreeListComBorderReqDto.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1558499_1_61641
                if (queryDeptDetailComBorderRespDto != null) {
                    querySubordinateDeptTreeListComBorderReqDto.setDeptCode(queryDeptDetailComBorderRespDto.getDeptCode());//SimpleFieldAssign//sourceId:1558497_1_61641
                }

                /*D1-3查询下级部门树状结构(公共)(边界)[1845]   */
                Assert.isNull(querySubordinateDeptTreeListComBorderReqDto.getDeptCode(), "D3执行分享到部门大家想法(公共)-D1-3查询下级部门树状结构(公共)(边界)-部门标识不能为空", false);
                Assert.isNull(querySubordinateDeptTreeListComBorderReqDto.getSubjectLifeCycle(), "D3执行分享到部门大家想法(公共)-D1-3查询下级部门树状结构(公共)(边界)-主体生命周期不能为空", false);
                querySubordinateDeptTreeListComBorderRespDto = orgService.querySubordinateDeptTreeListComBorder(querySubordinateDeptTreeListComBorderReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
                Assert.isTrue(querySubordinateDeptTreeListComBorderRespDto == null || querySubordinateDeptTreeListComBorderRespDto.getDeptList() == null || CollectionUtil.isEmpty(querySubordinateDeptTreeListComBorderRespDto.getDeptList()) || querySubordinateDeptTreeListComBorderRespDto.getDeptList().size() == 0, "找不到数据，系统异常", false);


            }
            ImplementDeptInductionComRespDto implementDeptInductionComRespDto = null;
            if (querySubordinateDeptTreeListComBorderRespDto != null) {
                ImplementDeptInductionComReqDto implementDeptInductionComReqDto = new ImplementDeptInductionComReqDto();
                implementDeptInductionComReqDto.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1558505_1_61642
                implementDeptInductionComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1558506_1_61642
                if (querySubordinateDeptTreeListComBorderRespDto != null && querySubordinateDeptTreeListComBorderRespDto.getDeptList() != null && !CollectionUtil.isEmpty(querySubordinateDeptTreeListComBorderRespDto.getDeptList())) {
                    implementDeptInductionComReqDto.setDeptMatchInductionList(querySubordinateDeptTreeListComBorderRespDto.getDeptList().stream().map(item -> item.getDeptId())
                            .collect(Collectors.toList()));/*list-to-strings*///sourceId:1558504_1_61642
                }

                /*D1执行批量部门查就职记录(公共)[8523]   */
                Assert.isNull(implementDeptInductionComReqDto.getSubjectLifeCycle(), "D3执行分享到部门大家想法(公共)-D1执行批量部门查就职记录(公共)-主体生命周期不能为空", false);
                Assert.isNull(implementDeptInductionComReqDto.getSpaceId(), "D3执行分享到部门大家想法(公共)-D1执行批量部门查就职记录(公共)-创建于空间ID不能为空", false);
                implementDeptInductionComRespDto = inductionRecordService.implementDeptInductionCom(implementDeptInductionComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
                Assert.isTrue(implementDeptInductionComRespDto == null || implementDeptInductionComRespDto.getDeptMatchInductionList() == null || CollectionUtil.isEmpty(implementDeptInductionComRespDto.getDeptMatchInductionList()) || implementDeptInductionComRespDto.getDeptMatchInductionList().size() == 0, "找不到数据，系统异常", false);


            }
            ObtainOrgMemberMsgReceiveInfoComRespDto obtainOrgMemberMsgReceiveInfoComRespDto = null;
            if (implementDeptInductionComRespDto != null) {
                ObtainOrgMemberMsgReceiveInfoComReqDto obtainOrgMemberMsgReceiveInfoComReqDto = new ObtainOrgMemberMsgReceiveInfoComReqDto();
                obtainOrgMemberMsgReceiveInfoComReqDto.setSenderOriginalRoleMemberId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecOriginalRoleMemberId());//CURRENT_ORIGINAL_ROLE_MEMBERID//sourceId:1508968_1_60257
                if (implementDeptInductionComRespDto != null && implementDeptInductionComRespDto.getDeptMatchInductionList() != null && !CollectionUtil.isEmpty(implementDeptInductionComRespDto.getDeptMatchInductionList())) {
                    obtainOrgMemberMsgReceiveInfoComReqDto.setBeginMemberList(implementDeptInductionComRespDto.getDeptMatchInductionList().stream().map(item -> item.getOriginalRoleMemberId())
                            .collect(Collectors.toList()));/*list-to-strings*///sourceId:1508967_1_60257
                }

                /*D1获取组织成员消息接收人信息(公共)[7972]   */
                Assert.isNull(obtainOrgMemberMsgReceiveInfoComReqDto.getSenderOriginalRoleMemberId(), "D3执行分享到部门大家想法(公共)-D1获取组织成员消息接收人信息(公共)-发送方身份人员ID不能为空", false);
                obtainOrgMemberMsgReceiveInfoComRespDto = messageService.obtainOrgMemberMsgReceiveInfoCom(obtainOrgMemberMsgReceiveInfoComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            }
            ImplementSendChannelMessageComRespDto implementSendChannelMessageComRespDto = null;
            if (obtainOrgMemberMsgReceiveInfoComRespDto != null && queryInductionRecordInfoDetailComRespDto != null && queryMessageDetailComRespDto != null && generateSemanticInstanceStoryComRespDto != null) {
                ImplementSendChannelMessageComReqDto implementSendChannelMessageComReqDto = new ImplementSendChannelMessageComReqDto();
                implementSendChannelMessageComReqDto.setBorcScene("TOB_SCENE");//sourceId:1508224_1_60261
                implementSendChannelMessageComReqDto.setPlatformReplace("FALSE");//sourceId:1508225_1_60261
                implementSendChannelMessageComReqDto.setMessageLocationTypeCode("RECORD_IDEAS");//CUSTOM_CONVENTION//sourceId:1508223_1_60261
                implementSendChannelMessageComReqDto.setChannelTypeCode("DEPT_IDEA_GROUP");//sourceId:1508226_1_60261
                implementSendChannelMessageComReqDto.setMsgChannelClassCode("IDEA");//sourceId:1508252_1_60261
                implementSendChannelMessageComReqDto.setNewTableTypeCode("OMS_ORG_DEPT");//sourceId:1508211_1_60261
                implementSendChannelMessageComReqDto.setGreetingMessageTemplateCode("TWO_PEOPLE_CHAT_DEFAULT_PROMPT_MESSAGE");//CUSTOM_CONVENTION//sourceId:1509547_1_60261
                implementSendChannelMessageComReqDto.setIsHandle("FALSE");//sourceId:1508237_1_60261
                implementSendChannelMessageComReqDto.setHandleType("NEED_HANDLING");//sourceId:1508249_1_60261
                implementSendChannelMessageComReqDto.setMessageImportantLevel(Long.valueOf(1));//CUSTOM_CONVENTION//sourceId:1508227_1_60261
                implementSendChannelMessageComReqDto.setMessageRole("user");//sourceId:1508216_1_60261
                implementSendChannelMessageComReqDto.setIsAssistant("FALSE");//sourceId:1508219_1_60261
                implementSendChannelMessageComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1508231_1_60261
                implementSendChannelMessageComReqDto.setAppId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecAppId());//CURRENT_APPID//sourceId:1508232_1_60261
                if (obtainOrgMemberMsgReceiveInfoComRespDto != null && obtainOrgMemberMsgReceiveInfoComRespDto.getMemberMsgReceiveList() != null && !CollectionUtil.isEmpty(obtainOrgMemberMsgReceiveInfoComRespDto.getMemberMsgReceiveList())) {
                    implementSendChannelMessageComReqDto.setMemberChannelList(obtainOrgMemberMsgReceiveInfoComRespDto.getMemberMsgReceiveList().stream().map(item -> BeanUtil.toBean(item, com.wicket.okrcomponent.integration.dto.MemberChannelDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1508222_1_60261
                }
                if (reqDto != null) {
                    implementSendChannelMessageComReqDto.setChannelName(reqDto.getChannelName());//SimpleFieldAssign//sourceId:1508209_1_60261
                    implementSendChannelMessageComReqDto.setNewEntityId(reqDto.getDeptId());//SimpleFieldAssign//sourceId:1508212_1_60261
                }
                if (queryInductionRecordInfoDetailComRespDto != null) {
                    implementSendChannelMessageComReqDto.setChannelLogo(queryInductionRecordInfoDetailComRespDto.getUserFace());//SimpleFieldAssign//sourceId:1508210_1_60261
                    implementSendChannelMessageComReqDto.setNameOfSender(queryInductionRecordInfoDetailComRespDto.getIdCardName());//SimpleFieldAssign//sourceId:1508215_1_60261
                    implementSendChannelMessageComReqDto.setSenderProfilePictureAddress(queryInductionRecordInfoDetailComRespDto.getUserFace());//SimpleFieldAssign//sourceId:1508214_1_60261
                    implementSendChannelMessageComReqDto.setSenderDeptId(queryInductionRecordInfoDetailComRespDto.getEntityId());//SimpleFieldAssign//sourceId:1508246_1_60261
                    implementSendChannelMessageComReqDto.setSenderInductionRecordId(queryInductionRecordInfoDetailComRespDto.getInductionRecordId());//SimpleFieldAssign//sourceId:1508247_1_60261
                    implementSendChannelMessageComReqDto.setSenderOriginalRoleMemberId(queryInductionRecordInfoDetailComRespDto.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1508217_1_60261
                    implementSendChannelMessageComReqDto.setSenderUserId(queryInductionRecordInfoDetailComRespDto.getUserId());//SimpleFieldAssign//sourceId:1508218_1_60261
                }
                if (queryMessageDetailComRespDto != null) {
                    implementSendChannelMessageComReqDto.setTableTypeCode(queryMessageDetailComRespDto.getSurfaceCode());//SimpleFieldAssign//sourceId:1508235_1_60261
                    implementSendChannelMessageComReqDto.setEntityId(queryMessageDetailComRespDto.getEntityId());//SimpleFieldAssign//sourceId:1508236_1_60261
                    implementSendChannelMessageComReqDto.setCooperateContentTypeCode(queryMessageDetailComRespDto.getCooperateContentTypeCode());//SimpleFieldAssign//sourceId:1508241_1_60261
                    implementSendChannelMessageComReqDto.setCooperateContentId(queryMessageDetailComRespDto.getCooperateContentId());//SimpleFieldAssign//sourceId:1508242_1_60261
                    implementSendChannelMessageComReqDto.setSurfaceContName(queryMessageDetailComRespDto.getSurfaceContName());//SimpleFieldAssign//sourceId:1508243_1_60261
                    implementSendChannelMessageComReqDto.setMediaType(queryMessageDetailComRespDto.getMediaType());//SimpleFieldAssign//sourceId:1508239_1_60261
                    implementSendChannelMessageComReqDto.setMediaAddress(queryMessageDetailComRespDto.getMediaAddress());//SimpleFieldAssign//sourceId:1508240_1_60261
                    implementSendChannelMessageComReqDto.setThemeContentTypeCode(queryMessageDetailComRespDto.getThemeContentTypeCode());//SimpleFieldAssign//sourceId:1508229_1_60261
                    implementSendChannelMessageComReqDto.setThemeContentId(queryMessageDetailComRespDto.getThemeContentId());//SimpleFieldAssign//sourceId:1508230_1_60261
                    implementSendChannelMessageComReqDto.setMessageTemplateCode(queryMessageDetailComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1508228_1_60261
                    implementSendChannelMessageComReqDto.setMessageTitle(queryMessageDetailComRespDto.getMessageTitle());//SimpleFieldAssign//sourceId:1508220_1_60261
                    implementSendChannelMessageComReqDto.setMessageContent(queryMessageDetailComRespDto.getMessageContent());//SimpleFieldAssign//sourceId:1508213_1_60261
                }
                if (generateSemanticInstanceStoryComRespDto != null) {
                    implementSendChannelMessageComReqDto.setNewMessage(generateSemanticInstanceStoryComRespDto.getObjectName());//SimpleFieldAssign//sourceId:1508233_1_60261
                }

                /*D2执行发送通道N人消息(初次或后续生成临时冗余的消息)[7494]   */
                Assert.isNull(implementSendChannelMessageComReqDto.getBorcScene(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-toB或toC场景不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getPlatformReplace(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-是否平台代操作不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getMessageLocationTypeCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息位置标识不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getChannelName(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道名称不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getChannelLogo(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道缩略图地址不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getChannelTypeCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道类型编码不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getMsgChannelClassCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息使用通道类别不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getNewTableTypeCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道归属主体内容类型编码不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getNewEntityId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道归属主体内容ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getTableTypeCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息归属内容表类型编码不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getEntityId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息归属内容表主键 ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getGreetingMessageTemplateCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-欢迎语消息模板标识不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getNewMessage(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-拉人进群欢迎消息文本不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getMessageTemplateCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息模板标识不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getMessageTitle(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息标题不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getMessageContent(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息内容不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getIsHandle(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-是否已处理不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getHandleType(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-处理类型不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getMessageImportantLevel(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息重要紧急度层级不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getNameOfSender(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方姓名不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getSenderProfilePictureAddress(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方头像地址不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getMessageRole(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方角色不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getSenderDeptId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方就职部门ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getSenderInductionRecordId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方就职记录ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getSenderOriginalRoleMemberId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方身份人员ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getSenderUserId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方账号ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getIsAssistant(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方是否助手不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getSpaceId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-创建于空间ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto.getAppId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-创建于联盟应用ID不能为空", false);
                implementSendChannelMessageComRespDto = fwCompMessageClient.implementSendChannelMessageCom(implementSendChannelMessageComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            }
            ImplementShareIdeasDeleteBackComRespDto implementShareIdeasDeleteBackComRespDto = null;
            if (implementSendChannelMessageComRespDto != null && queryMessageDetailComRespDto != null) {
                ImplementShareIdeasDeleteBackComReqDto implementShareIdeasDeleteBackComReqDto = new ImplementShareIdeasDeleteBackComReqDto();
                implementShareIdeasDeleteBackComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1508957_1_60262
                if (implementSendChannelMessageComRespDto != null) {
                    implementShareIdeasDeleteBackComReqDto.setMessageId(implementSendChannelMessageComRespDto.getMessageId());//SimpleFieldAssign//sourceId:1508955_1_60262
                }
                if (queryMessageDetailComRespDto != null) {
                    implementShareIdeasDeleteBackComReqDto.setReceiveMessageId(queryMessageDetailComRespDto.getMessageId());//SimpleFieldAssign//sourceId:1509762_1_60262
                }

                /*D2执行分享想法后回删(公共)[8360]   */
                Assert.isNull(implementShareIdeasDeleteBackComReqDto.getMessageId(), "D3执行分享到部门大家想法(公共)-D2执行分享想法后回删(公共)-消息ID不能为空", false);
                Assert.isNull(implementShareIdeasDeleteBackComReqDto.getReceiveMessageId(), "D3执行分享到部门大家想法(公共)-D2执行分享想法后回删(公共)-接收的消息ID不能为空", false);
                Assert.isNull(implementShareIdeasDeleteBackComReqDto.getSpaceId(), "D3执行分享到部门大家想法(公共)-D2执行分享想法后回删(公共)-创建于空间ID不能为空", false);
                implementShareIdeasDeleteBackComRespDto = fwCompCommunicationClient.implementShareIdeasDeleteBackCom(implementShareIdeasDeleteBackComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


            }
        } else {
            //else  60255

            ImplementSendChannelMessageComRespDto implementSendChannelMessageComRespDto_2 = null;
            if (queryInductionRecordInfoDetailComRespDto != null && queryMessageDetailComRespDto != null && generateSemanticInstanceStoryComRespDto != null) {
                ImplementSendChannelMessageComReqDto implementSendChannelMessageComReqDto_1 = new ImplementSendChannelMessageComReqDto();
                implementSendChannelMessageComReqDto_1.setBorcScene("TOB_SCENE");//sourceId:1508224_1_60263
                implementSendChannelMessageComReqDto_1.setPlatformReplace("FALSE");//sourceId:1508225_1_60263
                implementSendChannelMessageComReqDto_1.setMessageLocationTypeCode("RECORD_IDEAS");//CUSTOM_CONVENTION//sourceId:1508223_1_60263
                implementSendChannelMessageComReqDto_1.setChannelTypeCode("DEPT_IDEA_GROUP");//sourceId:1508226_1_60263
                implementSendChannelMessageComReqDto_1.setMsgChannelClassCode("IDEA");//sourceId:1508252_1_60263
                implementSendChannelMessageComReqDto_1.setNewTableTypeCode("OMS_ORG_DEPT");//sourceId:1508211_1_60263
                implementSendChannelMessageComReqDto_1.setGreetingMessageTemplateCode("TWO_PEOPLE_CHAT_DEFAULT_PROMPT_MESSAGE");//CUSTOM_CONVENTION//sourceId:1509547_1_60263
                implementSendChannelMessageComReqDto_1.setIsHandle("FALSE");//sourceId:1508237_1_60263
                implementSendChannelMessageComReqDto_1.setHandleType("NEED_HANDLING");//sourceId:1508249_1_60263
                implementSendChannelMessageComReqDto_1.setMessageImportantLevel(Long.valueOf(1));//CUSTOM_CONVENTION//sourceId:1508227_1_60263
                implementSendChannelMessageComReqDto_1.setMessageRole("user");//sourceId:1508216_1_60263
                implementSendChannelMessageComReqDto_1.setIsAssistant("FALSE");//sourceId:1508219_1_60263
                implementSendChannelMessageComReqDto_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1508231_1_60263
                implementSendChannelMessageComReqDto_1.setAppId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecAppId());//CURRENT_APPID//sourceId:1508232_1_60263
                if (reqDto != null) {
                    implementSendChannelMessageComReqDto_1.setChannelName(reqDto.getChannelName());//SimpleFieldAssign//sourceId:1508209_1_60263
                    implementSendChannelMessageComReqDto_1.setNewEntityId(reqDto.getDeptId());//SimpleFieldAssign//sourceId:1508212_1_60263
                }
                if (queryInductionRecordInfoDetailComRespDto != null) {
                    implementSendChannelMessageComReqDto_1.setChannelLogo(queryInductionRecordInfoDetailComRespDto.getUserFace());//SimpleFieldAssign//sourceId:1508210_1_60263
                    implementSendChannelMessageComReqDto_1.setNameOfSender(queryInductionRecordInfoDetailComRespDto.getIdCardName());//SimpleFieldAssign//sourceId:1508215_1_60263
                    implementSendChannelMessageComReqDto_1.setSenderProfilePictureAddress(queryInductionRecordInfoDetailComRespDto.getUserFace());//SimpleFieldAssign//sourceId:1508214_1_60263
                    implementSendChannelMessageComReqDto_1.setSenderDeptId(queryInductionRecordInfoDetailComRespDto.getEntityId());//SimpleFieldAssign//sourceId:1508246_1_60263
                    implementSendChannelMessageComReqDto_1.setSenderInductionRecordId(queryInductionRecordInfoDetailComRespDto.getInductionRecordId());//SimpleFieldAssign//sourceId:1508247_1_60263
                    implementSendChannelMessageComReqDto_1.setSenderOriginalRoleMemberId(queryInductionRecordInfoDetailComRespDto.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1508217_1_60263
                    implementSendChannelMessageComReqDto_1.setSenderUserId(queryInductionRecordInfoDetailComRespDto.getUserId());//SimpleFieldAssign//sourceId:1508218_1_60263
                }
                if (queryMessageDetailComRespDto != null) {
                    implementSendChannelMessageComReqDto_1.setTableTypeCode(queryMessageDetailComRespDto.getSurfaceCode());//SimpleFieldAssign//sourceId:1508235_1_60263
                    implementSendChannelMessageComReqDto_1.setEntityId(queryMessageDetailComRespDto.getEntityId());//SimpleFieldAssign//sourceId:1508236_1_60263
                    implementSendChannelMessageComReqDto_1.setCooperateContentTypeCode(queryMessageDetailComRespDto.getCooperateContentTypeCode());//SimpleFieldAssign//sourceId:1508241_1_60263
                    implementSendChannelMessageComReqDto_1.setCooperateContentId(queryMessageDetailComRespDto.getCooperateContentId());//SimpleFieldAssign//sourceId:1508242_1_60263
                    implementSendChannelMessageComReqDto_1.setSurfaceContName(queryMessageDetailComRespDto.getSurfaceContName());//SimpleFieldAssign//sourceId:1508243_1_60263
                    implementSendChannelMessageComReqDto_1.setMediaType(queryMessageDetailComRespDto.getMediaType());//SimpleFieldAssign//sourceId:1508239_1_60263
                    implementSendChannelMessageComReqDto_1.setMediaAddress(queryMessageDetailComRespDto.getMediaAddress());//SimpleFieldAssign//sourceId:1508240_1_60263
                    implementSendChannelMessageComReqDto_1.setThemeContentTypeCode(queryMessageDetailComRespDto.getThemeContentTypeCode());//SimpleFieldAssign//sourceId:1508229_1_60263
                    implementSendChannelMessageComReqDto_1.setThemeContentId(queryMessageDetailComRespDto.getThemeContentId());//SimpleFieldAssign//sourceId:1508230_1_60263
                    implementSendChannelMessageComReqDto_1.setMessageTemplateCode(queryMessageDetailComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1508228_1_60263
                    implementSendChannelMessageComReqDto_1.setMessageTitle(queryMessageDetailComRespDto.getMessageTitle());//SimpleFieldAssign//sourceId:1508220_1_60263
                    implementSendChannelMessageComReqDto_1.setMessageContent(queryMessageDetailComRespDto.getMessageContent());//SimpleFieldAssign//sourceId:1508213_1_60263
                }
                if (generateSemanticInstanceStoryComRespDto != null) {
                    implementSendChannelMessageComReqDto_1.setNewMessage(generateSemanticInstanceStoryComRespDto.getObjectName());//SimpleFieldAssign//sourceId:1508233_1_60263
                }

                /*D2执行发送通道N人消息(初次或后续生成临时冗余的消息)[7494]   */
                Assert.isNull(implementSendChannelMessageComReqDto_1.getBorcScene(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-toB或toC场景不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getPlatformReplace(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-是否平台代操作不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getMessageLocationTypeCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息位置标识不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getChannelName(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道名称不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getChannelLogo(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道缩略图地址不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getChannelTypeCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道类型编码不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getMsgChannelClassCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息使用通道类别不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getNewTableTypeCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道归属主体内容类型编码不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getNewEntityId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道归属主体内容ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getTableTypeCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息归属内容表类型编码不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getEntityId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息归属内容表主键 ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getGreetingMessageTemplateCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-欢迎语消息模板标识不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getNewMessage(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-拉人进群欢迎消息文本不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getMessageTemplateCode(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息模板标识不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getMessageTitle(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息标题不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getMessageContent(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息内容不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getIsHandle(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-是否已处理不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getHandleType(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-处理类型不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getMessageImportantLevel(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息重要紧急度层级不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getNameOfSender(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方姓名不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getSenderProfilePictureAddress(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方头像地址不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getMessageRole(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方角色不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getSenderDeptId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方就职部门ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getSenderInductionRecordId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方就职记录ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getSenderOriginalRoleMemberId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方身份人员ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getSenderUserId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方账号ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getIsAssistant(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方是否助手不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getSpaceId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-创建于空间ID不能为空", false);
                Assert.isNull(implementSendChannelMessageComReqDto_1.getAppId(), "D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-创建于联盟应用ID不能为空", false);
                implementSendChannelMessageComRespDto_2 = fwCompMessageClient.implementSendChannelMessageCom(implementSendChannelMessageComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;


            }
            ImplementShareIdeasDeleteBackComRespDto implementShareIdeasDeleteBackComRespDto_1 = null;
            if (implementSendChannelMessageComRespDto_2 != null && queryMessageDetailComRespDto != null) {
                ImplementShareIdeasDeleteBackComReqDto implementShareIdeasDeleteBackComReqDto_1 = new ImplementShareIdeasDeleteBackComReqDto();
                implementShareIdeasDeleteBackComReqDto_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1508957_1_60264
                if (implementSendChannelMessageComRespDto_2 != null) {
                    implementShareIdeasDeleteBackComReqDto_1.setMessageId(implementSendChannelMessageComRespDto_2.getMessageId());//SimpleFieldAssign//sourceId:1508955_1_60264
                }
                if (queryMessageDetailComRespDto != null) {
                    implementShareIdeasDeleteBackComReqDto_1.setReceiveMessageId(queryMessageDetailComRespDto.getMessageId());//SimpleFieldAssign//sourceId:1509762_1_60264
                }

                /*D2执行分享想法后回删(公共)[8360]   */
                Assert.isNull(implementShareIdeasDeleteBackComReqDto_1.getMessageId(), "D3执行分享到部门大家想法(公共)-D2执行分享想法后回删(公共)-消息ID不能为空", false);
                Assert.isNull(implementShareIdeasDeleteBackComReqDto_1.getReceiveMessageId(), "D3执行分享到部门大家想法(公共)-D2执行分享想法后回删(公共)-接收的消息ID不能为空", false);
                Assert.isNull(implementShareIdeasDeleteBackComReqDto_1.getSpaceId(), "D3执行分享到部门大家想法(公共)-D2执行分享想法后回删(公共)-创建于空间ID不能为空", false);
                implementShareIdeasDeleteBackComRespDto_1 = fwCompCommunicationClient.implementShareIdeasDeleteBackCom(implementShareIdeasDeleteBackComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;


            }
        }
        ImplementShareEveryoneIdeasDeptComRespDto retData = new ImplementShareEveryoneIdeasDeptComRespDto();


        return retData;
    }

    /**
     * D3分析高中基层回退消息模板(公共)[8495]
     * gen by moon at 2/13/2024, 10:43:01 AM
     */
    @Trace(operationName = "D3分析高中基层回退消息模板(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public AnalysisTopMidBaiscBackMsgTempComRespDto analysisTopMidBaiscBackMsgTempCom(AnalysisTopMidBaiscBackMsgTempComReqDto reqDto) {


        ObtainReceiveOutFieldRespDto receptionServiceRes_5 = null;
//virtualUsage M3约定高中基层回退操作消息模板标识  61341
        //ModelCode: receptionService
        ObtainReceiveOutFieldRespDto receptionServiceRes = null;
        ObtainReceiveOutFieldReqDto receptionServiceReq = new ObtainReceiveOutFieldReqDto();
        receptionServiceReq.setCustomField1("TOP_BACK_FIRST_STEP_MSG_TEMP");//CUSTOM_CONVENTION//sourceId:1546099_1_61341
        receptionServiceReq.setCustomField2("MID_BACK_FIRST_STEP_MSG_TEMP");//CUSTOM_CONVENTION//sourceId:1546104_1_61341
        receptionServiceReq.setCustomField3("MID_BACK_SEC_STEP_MSG_TEMP");//CUSTOM_CONVENTION//sourceId:1546105_1_61341
        receptionServiceReq.setCustomField4("BAISC_BACK_FIRST_STEP_MSG_TEMP");//CUSTOM_CONVENTION//sourceId:1546106_1_61341

        /*M3约定高中基层回退操作消息模板标识[4608]  用于特殊方法接收上游入参。 */
        Assert.isNull(receptionServiceReq.getCustomField1(), "D3分析高中基层回退消息模板(公共)-M3约定高中基层回退操作消息模板标识-自定义字段1不能为空", false);
        Assert.isNull(receptionServiceReq.getCustomField2(), "D3分析高中基层回退消息模板(公共)-M3约定高中基层回退操作消息模板标识-自定义字段2不能为空", false);
        Assert.isNull(receptionServiceReq.getCustomField3(), "D3分析高中基层回退消息模板(公共)-M3约定高中基层回退操作消息模板标识-自定义字段3不能为空", false);
        Assert.isNull(receptionServiceReq.getCustomField4(), "D3分析高中基层回退消息模板(公共)-M3约定高中基层回退操作消息模板标识-自定义字段4不能为空", false);
        receptionServiceRes = nbCommunication.obtainReceiveOutField(receptionServiceReq);


//virtualUsage M3约定高中基层回退消息标题语义引擎标识  61342
        //ModelCode: receptionService
        ObtainReceiveOutFieldRespDto receptionServiceRes_2 = null;
        ObtainReceiveOutFieldReqDto receptionServiceReq_1 = new ObtainReceiveOutFieldReqDto();
        receptionServiceReq_1.setCustomField1("TOP_BACK_FIRST_STEP_MSG_TITLE");//CUSTOM_CONVENTION//sourceId:1546411_1_61342
        receptionServiceReq_1.setCustomField2("MID_BACK_FIRST_STEP_MSG_TITLE");//CUSTOM_CONVENTION//sourceId:1546412_1_61342
        receptionServiceReq_1.setCustomField3("MID_BACK_SEC_STEP_MSG_TITLE");//CUSTOM_CONVENTION//sourceId:1546413_1_61342
        receptionServiceReq_1.setCustomField4("BAISC_BACK_FIRST_STEP_MSG_TITLE");//CUSTOM_CONVENTION//sourceId:1546414_1_61342

        /*M3约定高中基层回退消息标题语义引擎标识[4608]  用于特殊方法接收上游入参。 */
        Assert.isNull(receptionServiceReq_1.getCustomField1(), "D3分析高中基层回退消息模板(公共)-M3约定高中基层回退消息标题语义引擎标识-自定义字段1不能为空", false);
        Assert.isNull(receptionServiceReq_1.getCustomField2(), "D3分析高中基层回退消息模板(公共)-M3约定高中基层回退消息标题语义引擎标识-自定义字段2不能为空", false);
        Assert.isNull(receptionServiceReq_1.getCustomField3(), "D3分析高中基层回退消息模板(公共)-M3约定高中基层回退消息标题语义引擎标识-自定义字段3不能为空", false);
        Assert.isNull(receptionServiceReq_1.getCustomField4(), "D3分析高中基层回退消息模板(公共)-M3约定高中基层回退消息标题语义引擎标识-自定义字段4不能为空", false);
        receptionServiceRes_2 = nbCommunication.obtainReceiveOutField(receptionServiceReq_1);


        if ((reqDto != null && reqDto.getSendMsgScene() != null && reqDto.getSendMsgScene().equals("TOP_BACK_FIRST_STEP"))) {
            //if(D3分析高中基层回退消息模板(公共).发送消息场景 等于 高层返回第一步)  61337

//ModelCode: receptionService
            ObtainReceiveOutFieldRespDto receptionServiceRes_4 = null;
            ObtainReceiveOutFieldReqDto receptionServiceReq_2 = new ObtainReceiveOutFieldReqDto();
            if (receptionServiceRes != null) {
                receptionServiceReq_2.setMessageTemplateCode(receptionServiceRes.getCustomField1());//SimpleFieldAssign//sourceId:1546089_1_61343
            }
            if (receptionServiceRes_2 != null) {
                receptionServiceReq_2.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_2.getCustomField1());//SimpleFieldAssign//sourceId:1546090_1_61343
            }

            /*M3接收消息模板及消息标题引擎模板[4608]  用于特殊方法接收上游入参。 */
            Assert.isNull(receptionServiceReq_2.getMessageTemplateCode(), "D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息模板标识不能为空", false);
            Assert.isNull(receptionServiceReq_2.getMsgTitleTemplateSemanticEngineCode(), "D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息标题模板引擎标识不能为空", false);
            receptionServiceRes_4 = nbCommunication.obtainReceiveOutField(receptionServiceReq_2);


            receptionServiceRes_5 = receptionServiceRes_4;
        } else if ((reqDto != null && reqDto.getSendMsgScene() != null && reqDto.getSendMsgScene().equals("MID_BACK_FIRST_STEP"))) {
            //elseif(D3分析高中基层回退消息模板(公共).发送消息场景 等于 中层返回第一步)  61338

//ModelCode: receptionService
            ObtainReceiveOutFieldRespDto receptionServiceRes_6 = null;
            ObtainReceiveOutFieldReqDto receptionServiceReq_3 = new ObtainReceiveOutFieldReqDto();
            if (receptionServiceRes != null) {
                receptionServiceReq_3.setMessageTemplateCode(receptionServiceRes.getCustomField2());//SimpleFieldAssign//sourceId:1546089_1_61344
            }
            if (receptionServiceRes_2 != null) {
                receptionServiceReq_3.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_2.getCustomField2());//SimpleFieldAssign//sourceId:1546090_1_61344
            }

            /*M3接收消息模板及消息标题引擎模板[4608]  用于特殊方法接收上游入参。 */
            Assert.isNull(receptionServiceReq_3.getMessageTemplateCode(), "D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息模板标识不能为空", false);
            Assert.isNull(receptionServiceReq_3.getMsgTitleTemplateSemanticEngineCode(), "D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息标题模板引擎标识不能为空", false);
            receptionServiceRes_6 = nbCommunication.obtainReceiveOutField(receptionServiceReq_3);


            receptionServiceRes_5 = receptionServiceRes_6;
        } else if ((reqDto != null && reqDto.getSendMsgScene() != null && reqDto.getSendMsgScene().equals("MID_BACK_SEC_STEP"))) {
            //elseif(D3分析高中基层回退消息模板(公共).发送消息场景 等于 中层返回第二步)  61339

//ModelCode: receptionService
            ObtainReceiveOutFieldRespDto receptionServiceRes_7 = null;
            ObtainReceiveOutFieldReqDto receptionServiceReq_4 = new ObtainReceiveOutFieldReqDto();
            if (receptionServiceRes != null) {
                receptionServiceReq_4.setMessageTemplateCode(receptionServiceRes.getCustomField3());//SimpleFieldAssign//sourceId:1546089_1_61345
            }
            if (receptionServiceRes_2 != null) {
                receptionServiceReq_4.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_2.getCustomField3());//SimpleFieldAssign//sourceId:1546090_1_61345
            }

            /*M3接收消息模板及消息标题引擎模板[4608]  用于特殊方法接收上游入参。 */
            Assert.isNull(receptionServiceReq_4.getMessageTemplateCode(), "D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息模板标识不能为空", false);
            Assert.isNull(receptionServiceReq_4.getMsgTitleTemplateSemanticEngineCode(), "D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息标题模板引擎标识不能为空", false);
            receptionServiceRes_7 = nbCommunication.obtainReceiveOutField(receptionServiceReq_4);


            receptionServiceRes_5 = receptionServiceRes_7;
        } else if ((reqDto != null && reqDto.getSendMsgScene() != null && reqDto.getSendMsgScene().equals("BAISC_BACK_FIRST_STEP"))) {
            //elseif(D3分析高中基层回退消息模板(公共).发送消息场景 等于 基层返回第一步)  61340

//ModelCode: receptionService
            ObtainReceiveOutFieldRespDto receptionServiceRes_8 = null;
            ObtainReceiveOutFieldReqDto receptionServiceReq_5 = new ObtainReceiveOutFieldReqDto();
            if (receptionServiceRes != null) {
                receptionServiceReq_5.setMessageTemplateCode(receptionServiceRes.getCustomField4());//SimpleFieldAssign//sourceId:1546089_1_61346
            }
            if (receptionServiceRes_2 != null) {
                receptionServiceReq_5.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_2.getCustomField4());//SimpleFieldAssign//sourceId:1546090_1_61346
            }

            /*M3接收消息模板及消息标题引擎模板[4608]  用于特殊方法接收上游入参。 */
            Assert.isNull(receptionServiceReq_5.getMessageTemplateCode(), "D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息模板标识不能为空", false);
            Assert.isNull(receptionServiceReq_5.getMsgTitleTemplateSemanticEngineCode(), "D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息标题模板引擎标识不能为空", false);
            receptionServiceRes_8 = nbCommunication.obtainReceiveOutField(receptionServiceReq_5);


            receptionServiceRes_5 = receptionServiceRes_8;
        }
        AnalysisTopMidBaiscBackMsgTempComRespDto retData = new AnalysisTopMidBaiscBackMsgTempComRespDto();
        if (receptionServiceRes_5 != null) {
            retData.setMessageTemplateCode(receptionServiceRes_5.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1546097_1
            retData.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_5.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1546098_1
        }


        return retData;
    }

    /**
     * D3执行预制内容发两人会话消息(公共)[8496]
     * gen by moon at 2/13/2024, 10:43:17 AM
     */
    @Trace(operationName = "D3执行预制内容发两人会话消息(公共)")
    @Tags({@Tag(key = "参数", value = "arg[0]"),
            @Tag(key = "返回值", value = "returnedObj")})
    @Transactional(rollbackFor = Exception.class)
    @Override
    public ImplementPrefabricateContentSendTwoPersonConvMsgComRespDto implementPrefabricateContentSendTwoPersonConvMsgCom(ImplementPrefabricateContentSendTwoPersonConvMsgComReqDto reqDto) {


        //步骤0: M3-执行发送消息接收人范围专用接收字段（特殊方法） - implementSendMsgReceiverAcceptField
        //ModelCode: receptionService
        ImplementSendMsgReceiverAcceptFieldRespDto receptionServiceRes = null;
        ImplementSendMsgReceiverAcceptFieldReqDto receptionServiceReq = new ImplementSendMsgReceiverAcceptFieldReqDto();
        if (reqDto != null) {
            receptionServiceReq.setSendMsgScene(reqDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1546987_1
            receptionServiceReq.setRoleCode(reqDto.getRoleCode());//SimpleFieldAssign//sourceId:1546988_1
            receptionServiceReq.setUseScene(reqDto.getUseScene());//SimpleFieldAssign//sourceId:1546989_1
            receptionServiceReq.setIsArchive(reqDto.getIsArchive());//SimpleFieldAssign//sourceId:1546990_1
            receptionServiceReq.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1546991_1
            receptionServiceReq.setReceiveOriginalRoleMemberId(reqDto.getReceiveOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1546992_1
            receptionServiceReq.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1546993_1
            receptionServiceReq.setAppId(reqDto.getAppId());//SimpleFieldAssign//sourceId:1546994_1
            receptionServiceReq.setNewTableTypeCode(reqDto.getNewTableTypeCode());//SimpleFieldAssign//sourceId:1547036_1
            receptionServiceReq.setNewEntityId(reqDto.getNewEntityId());//SimpleFieldAssign//sourceId:1547037_1
            receptionServiceReq.setSurfaceCode(reqDto.getSurfaceCode());//SimpleFieldAssign//sourceId:1547038_1
            receptionServiceReq.setEntityId(reqDto.getEntityId());//SimpleFieldAssign//sourceId:1547039_1
            receptionServiceReq.setPlatformReplace(reqDto.getPlatformReplace());//SimpleFieldAssign//sourceId:1547001_1
            receptionServiceReq.setMessageTemplateCode(reqDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1547000_1
            receptionServiceReq.setMsgTitleTemplateSemanticEngineCode(reqDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1547004_1
            receptionServiceReq.setMessageImportantLevel(reqDto.getMessageImportantLevel());//SimpleFieldAssign//sourceId:1547003_1
            receptionServiceReq.setMessageContent(reqDto.getMessageContent());//SimpleFieldAssign//sourceId:1547034_1
            receptionServiceReq.setReferenceMessageId(reqDto.getReferenceMessageId());//SimpleFieldAssign//sourceId:1547002_1
            receptionServiceReq.setCooperateContentTypeCode(reqDto.getCooperateContentTypeCode());//SimpleFieldAssign//sourceId:1546995_1
            receptionServiceReq.setCooperateContentId(reqDto.getCooperateContentId());//SimpleFieldAssign//sourceId:1546996_1
            receptionServiceReq.setSurfaceContName(reqDto.getSurfaceContName());//SimpleFieldAssign//sourceId:1546997_1
            receptionServiceReq.setMediaType(reqDto.getMediaType());//SimpleFieldAssign//sourceId:1546998_1
            receptionServiceReq.setMediaAddress(reqDto.getMediaAddress());//SimpleFieldAssign//sourceId:1546999_1
            receptionServiceReq.setIsHandle(reqDto.getIsHandle());//SimpleFieldAssign//sourceId:1547044_1
            receptionServiceReq.setHandleType(reqDto.getHandleType());//SimpleFieldAssign//sourceId:1547045_1
            receptionServiceReq.setComNumField(reqDto.getComNumField());//SimpleFieldAssign//sourceId:1547005_1
        }

        /*M3接收字段[8209]  用于特殊方法接收上游入参。 */
        Assert.isNull(receptionServiceReq.getSendMsgScene(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-发送消息场景不能为空", false);
        Assert.isNull(receptionServiceReq.getReceiveOriginalRoleMemberId(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-接收方身份人员ID不能为空", false);
        Assert.isNull(receptionServiceReq.getSpaceId(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-创建于空间ID不能为空", false);
        Assert.isNull(receptionServiceReq.getAppId(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-创建于联盟应用ID不能为空", false);
        Assert.isNull(receptionServiceReq.getNewTableTypeCode(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-通道归属主体内容类型编码不能为空", false);
        Assert.isNull(receptionServiceReq.getNewEntityId(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-通道归属主体内容ID不能为空", false);
        Assert.isNull(receptionServiceReq.getSurfaceCode(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-归属内容类型编码不能为空", false);
        Assert.isNull(receptionServiceReq.getEntityId(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-归属内容ID不能为空", false);
        Assert.isNull(receptionServiceReq.getPlatformReplace(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-是否平台代操作不能为空", false);
        Assert.isNull(receptionServiceReq.getMessageTemplateCode(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-消息模板标识不能为空", false);
        Assert.isNull(receptionServiceReq.getMsgTitleTemplateSemanticEngineCode(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-消息标题模板引擎标识不能为空", false);
        Assert.isNull(receptionServiceReq.getMessageImportantLevel(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-消息重要紧急度层级不能为空", false);
        Assert.isNull(receptionServiceReq.getMessageContent(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-消息内容不能为空", false);
        Assert.isNull(receptionServiceReq.getHandleType(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-处理类型不能为空", false);
        Assert.isNull(receptionServiceReq.getComNumField(), "D3执行预制内容发两人会话消息(公共)-M3接收字段-通用数值字段（整数型）不能为空", false);
        receptionServiceRes = nbCommunication.implementSendMsgReceiverAcceptField(receptionServiceReq);


//步骤1: D3分析批次内消息发送方身份信息(公共) - analysisBatchMessageSenderInfoCom
        AnalysisBatchMessageSenderInfoComRespDto analysisBatchMessageSenderInfoComRespDto = null;
        AnalysisBatchMessageSenderInfoComReqDto analysisBatchMessageSenderInfoComReqDto = new AnalysisBatchMessageSenderInfoComReqDto();
        if (reqDto != null) {
            analysisBatchMessageSenderInfoComReqDto.setSendMsgScene(reqDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1546830_1
            analysisBatchMessageSenderInfoComReqDto.setRoleCode(reqDto.getRoleCode());//SimpleFieldAssign//sourceId:1546849_1
            analysisBatchMessageSenderInfoComReqDto.setUseScene(reqDto.getUseScene());//SimpleFieldAssign//sourceId:1546831_1
            analysisBatchMessageSenderInfoComReqDto.setEntityId(reqDto.getNewTableTypeCode());//SimpleFieldAssign//sourceId:1546832_1
            analysisBatchMessageSenderInfoComReqDto.setIsArchive(reqDto.getIsArchive());//SimpleFieldAssign//sourceId:1546833_1
            analysisBatchMessageSenderInfoComReqDto.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1546834_1
        }

        /*D3分析批次内消息发送方身份信息(公共)[8281]   */
        Assert.isNull(analysisBatchMessageSenderInfoComReqDto.getSendMsgScene(), "D3执行预制内容发两人会话消息(公共)-D3分析批次内消息发送方身份信息(公共)-发送消息场景不能为空", false);
        analysisBatchMessageSenderInfoComRespDto = messageService.analysisBatchMessageSenderInfoCom(analysisBatchMessageSenderInfoComReqDto)/*vcase invoke isSameApp*/;


//步骤2: D1-3查询就职记录详情(公共)(边界) - queryInductionRecordDetailComBorder
        QueryInductionRecordDetailComBorderRespDto queryInductionRecordDetailComBorderRespDto = null;
        QueryInductionRecordDetailComBorderReqDto queryInductionRecordDetailComBorderReqDto = new QueryInductionRecordDetailComBorderReqDto();
        queryInductionRecordDetailComBorderReqDto.setIsMainInduction("TRUE");//sourceId:1546807_1
        queryInductionRecordDetailComBorderReqDto.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1547133_1
        if (reqDto != null) {
            queryInductionRecordDetailComBorderReqDto.setOriginalRoleMemberId(reqDto.getReceiveOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1546805_1
            queryInductionRecordDetailComBorderReqDto.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1546813_1
        }

        /*D1-3查消息接收方信息[1340]   */
        Assert.isNull(queryInductionRecordDetailComBorderReqDto.getOriginalRoleMemberId(), "D3执行预制内容发两人会话消息(公共)-D1-3查消息接收方信息-身份人员ID不能为空", false);
        Assert.isNull(queryInductionRecordDetailComBorderReqDto.getIsMainInduction(), "D3执行预制内容发两人会话消息(公共)-D1-3查消息接收方信息-是否主岗不能为空", false);
        Assert.isNull(queryInductionRecordDetailComBorderReqDto.getSubjectLifeCycle(), "D3执行预制内容发两人会话消息(公共)-D1-3查消息接收方信息-主体生命周期不能为空", false);
        Assert.isNull(queryInductionRecordDetailComBorderReqDto.getSpaceId(), "D3执行预制内容发两人会话消息(公共)-D1-3查消息接收方信息-创建于空间ID不能为空", false);
        queryInductionRecordDetailComBorderRespDto = inductionRecordService.queryInductionRecordDetailComBorder(queryInductionRecordDetailComBorderReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


//步骤3: D2生成语义实例故事(公共) - generateSemanticInstanceStoryCom
        GenerateSemanticInstanceStoryComRespDto generateSemanticInstanceStoryComRespDto = null;
        if (analysisBatchMessageSenderInfoComRespDto != null) {
            GenerateSemanticInstanceStoryComReqDto generateSemanticInstanceStoryComReqDto = new GenerateSemanticInstanceStoryComReqDto();
            generateSemanticInstanceStoryComReqDto.setFirstFieldName("idCardName");//CUSTOM_CONVENTION//sourceId:1547134_1
            if (reqDto != null) {
                generateSemanticInstanceStoryComReqDto.setTemplateSemanticEngineCode(reqDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1547140_1
            }
            if (analysisBatchMessageSenderInfoComRespDto != null) {
                generateSemanticInstanceStoryComReqDto.setFirstFieldValue(analysisBatchMessageSenderInfoComRespDto.getNameOfSender());//SimpleFieldAssign//sourceId:1547135_1
            }

            /*D2生成消息标题语义内容公共)[8234]   */
            Assert.isNull(generateSemanticInstanceStoryComReqDto.getTemplateSemanticEngineCode(), "D3执行预制内容发两人会话消息(公共)-D2生成消息标题语义内容公共)-模板引擎标识不能为空", false);
            Assert.isNull(generateSemanticInstanceStoryComReqDto.getFirstFieldName(), "D3执行预制内容发两人会话消息(公共)-D2生成消息标题语义内容公共)-第一个字段字段名不能为空", false);
            Assert.isNull(generateSemanticInstanceStoryComReqDto.getFirstFieldValue(), "D3执行预制内容发两人会话消息(公共)-D2生成消息标题语义内容公共)-第一个字段字段值不能为空", false);
            generateSemanticInstanceStoryComRespDto = fwCompTemplateEngineClient.generateSemanticInstanceStoryCom(generateSemanticInstanceStoryComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


        }

//步骤4: D2生成语义实例故事(公共) - generateSemanticInstanceStoryCom
        GenerateSemanticInstanceStoryComRespDto generateSemanticInstanceStoryComRespDto_2 = null;
        if (analysisBatchMessageSenderInfoComRespDto != null) {
            GenerateSemanticInstanceStoryComReqDto generateSemanticInstanceStoryComReqDto_1 = new GenerateSemanticInstanceStoryComReqDto();
            generateSemanticInstanceStoryComReqDto_1.setTemplateSemanticEngineCode("TWO_PEOPLE_CHAT_DEFAULT_PROMPT_MESSAGE");//CUSTOM_CONVENTION//sourceId:1547148_1
            generateSemanticInstanceStoryComReqDto_1.setFirstFieldName("idCardName");//CUSTOM_CONVENTION//sourceId:1547142_1
            if (analysisBatchMessageSenderInfoComRespDto != null) {
                generateSemanticInstanceStoryComReqDto_1.setFirstFieldValue(analysisBatchMessageSenderInfoComRespDto.getNameOfSender());//SimpleFieldAssign//sourceId:1547143_1
            }

            /*D2生成“xx”邀请多人加入小岛[8234]   */
            Assert.isNull(generateSemanticInstanceStoryComReqDto_1.getTemplateSemanticEngineCode(), "D3执行预制内容发两人会话消息(公共)-D2生成“xx”邀请多人加入小岛-模板引擎标识不能为空", false);
            Assert.isNull(generateSemanticInstanceStoryComReqDto_1.getFirstFieldName(), "D3执行预制内容发两人会话消息(公共)-D2生成“xx”邀请多人加入小岛-第一个字段字段名不能为空", false);
            Assert.isNull(generateSemanticInstanceStoryComReqDto_1.getFirstFieldValue(), "D3执行预制内容发两人会话消息(公共)-D2生成“xx”邀请多人加入小岛-第一个字段字段值不能为空", false);
            generateSemanticInstanceStoryComRespDto_2 = fwCompTemplateEngineClient.generateSemanticInstanceStoryCom(generateSemanticInstanceStoryComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;


        }

//步骤5: D3分析通道名称缩略图(公共) - analysisChannelNameImageCom
        AnalysisChannelNameImageComRespDto analysisChannelNameImageComRespDto = null;
        if (analysisBatchMessageSenderInfoComRespDto != null) {
            AnalysisChannelNameImageComReqDto analysisChannelNameImageComReqDto = new AnalysisChannelNameImageComReqDto();
            if (reqDto != null) {
                analysisChannelNameImageComReqDto.setSendMsgScene(reqDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1546801_1
                analysisChannelNameImageComReqDto.setTableTypeCode(reqDto.getNewTableTypeCode());//SimpleFieldAssign//sourceId:1546799_1
                analysisChannelNameImageComReqDto.setEntityId(reqDto.getNewEntityId());//SimpleFieldAssign//sourceId:1546798_1
                analysisChannelNameImageComReqDto.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1546800_1
            }
            if (analysisBatchMessageSenderInfoComRespDto != null) {
                analysisChannelNameImageComReqDto.setSenderOriginalRoleMemberId(analysisBatchMessageSenderInfoComRespDto.getSenderOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1546802_1
            }

            /*D3分析通道名称缩略图(公共)[8241]   */
            Assert.isNull(analysisChannelNameImageComReqDto.getSendMsgScene(), "D3执行预制内容发两人会话消息(公共)-D3分析通道名称缩略图(公共)-发送消息场景不能为空", false);
            Assert.isNull(analysisChannelNameImageComReqDto.getTableTypeCode(), "D3执行预制内容发两人会话消息(公共)-D3分析通道名称缩略图(公共)-通道归属主体内容类型编码不能为空", false);
            Assert.isNull(analysisChannelNameImageComReqDto.getEntityId(), "D3执行预制内容发两人会话消息(公共)-D3分析通道名称缩略图(公共)-通道归属主体内容ID不能为空", false);
            Assert.isNull(analysisChannelNameImageComReqDto.getSpaceId(), "D3执行预制内容发两人会话消息(公共)-D3分析通道名称缩略图(公共)-创建于空间ID不能为空", false);
            analysisChannelNameImageComRespDto = messageService.analysisChannelNameImageCom(analysisChannelNameImageComReqDto)/*vcase invoke isSameApp*/;


        }

//步骤6: D3执行消息主题内容分析(公共) - implementMsgThemeContentanAlyseCom
        ImplementMsgThemeContentanAlyseComRespDto implementMsgThemeContentanAlyseComRespDto = null;
        ImplementMsgThemeContentanAlyseComReqDto implementMsgThemeContentanAlyseComReqDto = new ImplementMsgThemeContentanAlyseComReqDto();
        if (reqDto != null) {
            implementMsgThemeContentanAlyseComReqDto.setTableTypeCode(reqDto.getSurfaceCode());//SimpleFieldAssign//sourceId:1546828_1
            implementMsgThemeContentanAlyseComReqDto.setEntityId(reqDto.getEntityId());//SimpleFieldAssign//sourceId:1546829_1
        }

        /*D3执行消息主题内容分析(公共)[8129]   */
        Assert.isNull(implementMsgThemeContentanAlyseComReqDto.getTableTypeCode(), "D3执行预制内容发两人会话消息(公共)-D3执行消息主题内容分析(公共)-冗余内容表类型编码不能为空", false);
        Assert.isNull(implementMsgThemeContentanAlyseComReqDto.getEntityId(), "D3执行预制内容发两人会话消息(公共)-D3执行消息主题内容分析(公共)-冗余内容表主键ID不能为空", false);
        implementMsgThemeContentanAlyseComRespDto = messageService.implementMsgThemeContentanAlyseCom(implementMsgThemeContentanAlyseComReqDto)/*vcase invoke isSameApp*/;


//步骤7: D2执行全场景两人会话(公共) - implementFullSceneTwoPersonConversationCom
        ImplementFullSceneTwoPersonConversationComRespDto implementFullSceneTwoPersonConversationComRespDto = null;
        if (analysisChannelNameImageComRespDto != null) {
            ImplementFullSceneTwoPersonConversationComReqDto implementFullSceneTwoPersonConversationComReqDto = new ImplementFullSceneTwoPersonConversationComReqDto();
            implementFullSceneTwoPersonConversationComReqDto.setUseChannelMethod("ISHAVE_CHANNEL");//sourceId:1546437_1
            implementFullSceneTwoPersonConversationComReqDto.setMessagePromptType("NUMBER_TYPE");//sourceId:1546495_1
            implementFullSceneTwoPersonConversationComReqDto.setBorcScene("TOB_SCENE");//sourceId:1546438_1
            implementFullSceneTwoPersonConversationComReqDto.setMessageLocationCode("NOTIFICATION_ANNOUNCEMENT");//CUSTOM_CONVENTION//sourceId:1546439_1
            implementFullSceneTwoPersonConversationComReqDto.setMsgChannelClassCode("NOTIFICATION_ANNOUNCEMENT");//sourceId:1546442_1
            implementFullSceneTwoPersonConversationComReqDto.setChannelTypeCode("PERSONAL_SESSION");//sourceId:1546443_1
            implementFullSceneTwoPersonConversationComReqDto.setOperateTime(CommonFunctionHelper.getCurrentTime());//SYSTEM_CURRENT_TIME//sourceId:1546485_1
            implementFullSceneTwoPersonConversationComReqDto.setFirstFieldName("idCardName");//CUSTOM_CONVENTION//sourceId:1546487_1
            if (reqDto != null) {
                implementFullSceneTwoPersonConversationComReqDto.setPlatformReplace(reqDto.getPlatformReplace());//SimpleFieldAssign//sourceId:1546441_1
                implementFullSceneTwoPersonConversationComReqDto.setMessageTemplateCode(reqDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1546440_1
                implementFullSceneTwoPersonConversationComReqDto.setNewTableTypeCode(reqDto.getNewTableTypeCode());//SimpleFieldAssign//sourceId:1546446_1
                implementFullSceneTwoPersonConversationComReqDto.setNewEntityId(reqDto.getNewEntityId());//SimpleFieldAssign//sourceId:1546447_1
                implementFullSceneTwoPersonConversationComReqDto.setSurfaceCode(reqDto.getSurfaceCode());//SimpleFieldAssign//sourceId:1546448_1
                implementFullSceneTwoPersonConversationComReqDto.setEntityId(reqDto.getEntityId());//SimpleFieldAssign//sourceId:1546449_1
                implementFullSceneTwoPersonConversationComReqDto.setChannelSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1546451_1
                implementFullSceneTwoPersonConversationComReqDto.setChannelAppId(reqDto.getAppId());//SimpleFieldAssign//sourceId:1546452_1
                implementFullSceneTwoPersonConversationComReqDto.setCooperateContentTypeCode(reqDto.getCooperateContentTypeCode());//SimpleFieldAssign//sourceId:1546455_1
                implementFullSceneTwoPersonConversationComReqDto.setCooperateContentId(reqDto.getCooperateContentId());//SimpleFieldAssign//sourceId:1546456_1
                implementFullSceneTwoPersonConversationComReqDto.setSurfaceContName(reqDto.getSurfaceContName());//SimpleFieldAssign//sourceId:1546457_1
                implementFullSceneTwoPersonConversationComReqDto.setMediaType(reqDto.getMediaType());//SimpleFieldAssign//sourceId:1546458_1
                implementFullSceneTwoPersonConversationComReqDto.setMediaAddress(reqDto.getMediaAddress());//SimpleFieldAssign//sourceId:1546459_1
                implementFullSceneTwoPersonConversationComReqDto.setIsHandle(reqDto.getIsHandle());//SimpleFieldAssign//sourceId:1546460_1
                implementFullSceneTwoPersonConversationComReqDto.setHandleType(reqDto.getHandleType());//SimpleFieldAssign//sourceId:1546461_1
                implementFullSceneTwoPersonConversationComReqDto.setReferenceMessageId(reqDto.getReferenceMessageId());//SimpleFieldAssign//sourceId:1546462_1
                implementFullSceneTwoPersonConversationComReqDto.setMessageContent(reqDto.getMessageContent());//SimpleFieldAssign//sourceId:1546464_1
                implementFullSceneTwoPersonConversationComReqDto.setMessageImportantLevel(reqDto.getMessageImportantLevel());//SimpleFieldAssign//sourceId:1546466_1
                implementFullSceneTwoPersonConversationComReqDto.setComNumField(reqDto.getComNumField());//SimpleFieldAssign//sourceId:1546484_1
            }
            if (analysisChannelNameImageComRespDto != null) {
                implementFullSceneTwoPersonConversationComReqDto.setChannelName(analysisChannelNameImageComRespDto.getChannelName());//SimpleFieldAssign//sourceId:1546444_1
                implementFullSceneTwoPersonConversationComReqDto.setChannelLogo(analysisChannelNameImageComRespDto.getChannelLogo());//SimpleFieldAssign//sourceId:1546445_1
            }
            if (implementMsgThemeContentanAlyseComRespDto != null) {
                implementFullSceneTwoPersonConversationComReqDto.setThemeContentId(implementMsgThemeContentanAlyseComRespDto.getThemeContentId());//SimpleFieldAssign//sourceId:1546453_1
                implementFullSceneTwoPersonConversationComReqDto.setThemeContentTypeCode(implementMsgThemeContentanAlyseComRespDto.getThemeContentTypeCode());//SimpleFieldAssign//sourceId:1546454_1
            }
            if (generateSemanticInstanceStoryComRespDto != null) {
                implementFullSceneTwoPersonConversationComReqDto.setMessageTitle(generateSemanticInstanceStoryComRespDto.getObjectName());//SimpleFieldAssign//sourceId:1546463_1
            }
            if (generateSemanticInstanceStoryComRespDto_2 != null) {
                implementFullSceneTwoPersonConversationComReqDto.setNewMessage(generateSemanticInstanceStoryComRespDto_2.getObjectName());//SimpleFieldAssign//sourceId:1546465_1
            }
            if (analysisBatchMessageSenderInfoComRespDto != null) {
                implementFullSceneTwoPersonConversationComReqDto.setIsAssistant(analysisBatchMessageSenderInfoComRespDto.getIsAssistant());//SimpleFieldAssign//sourceId:1546467_1
                implementFullSceneTwoPersonConversationComReqDto.setMessageRole(analysisBatchMessageSenderInfoComRespDto.getMessageRole());//SimpleFieldAssign//sourceId:1546468_1
                implementFullSceneTwoPersonConversationComReqDto.setSenderDeptId(analysisBatchMessageSenderInfoComRespDto.getSenderDeptId());//SimpleFieldAssign//sourceId:1546469_1
                implementFullSceneTwoPersonConversationComReqDto.setSenderVirtualOrgMemberId(analysisBatchMessageSenderInfoComRespDto.getSenderVirtualOrgMemberId());//SimpleFieldAssign//sourceId:1546470_1
                implementFullSceneTwoPersonConversationComReqDto.setSenderInductionRecordId(analysisBatchMessageSenderInfoComRespDto.getSenderInductionRecordId());//SimpleFieldAssign//sourceId:1546471_1
                implementFullSceneTwoPersonConversationComReqDto.setSenderOriginalRoleMemberId(analysisBatchMessageSenderInfoComRespDto.getSenderOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1546472_1
                implementFullSceneTwoPersonConversationComReqDto.setSenderUserId(analysisBatchMessageSenderInfoComRespDto.getSenderUserId());//SimpleFieldAssign//sourceId:1546473_1
                implementFullSceneTwoPersonConversationComReqDto.setNameOfSender(analysisBatchMessageSenderInfoComRespDto.getNameOfSender());//SimpleFieldAssign//sourceId:1546474_1
                implementFullSceneTwoPersonConversationComReqDto.setSenderProfilePictureAddress(analysisBatchMessageSenderInfoComRespDto.getSenderProfilePictureAddress());//SimpleFieldAssign//sourceId:1546475_1
                implementFullSceneTwoPersonConversationComReqDto.setSenderSpaceId(analysisBatchMessageSenderInfoComRespDto.getSenderSpaceId());//SimpleFieldAssign//sourceId:1546476_1
                implementFullSceneTwoPersonConversationComReqDto.setSenderAppId(analysisBatchMessageSenderInfoComRespDto.getSenderAppId());//SimpleFieldAssign//sourceId:1546477_1
                implementFullSceneTwoPersonConversationComReqDto.setSmsBehaviorType(analysisBatchMessageSenderInfoComRespDto.getSmsBehaviorType());//SimpleFieldAssign//sourceId:1546486_1
                implementFullSceneTwoPersonConversationComReqDto.setFirstFieldValue(analysisBatchMessageSenderInfoComRespDto.getNameOfSender());//SimpleFieldAssign//sourceId:1546488_1
            }
            if (queryInductionRecordDetailComBorderRespDto != null) {
                implementFullSceneTwoPersonConversationComReqDto.setReceiveProfilePictureAddress(queryInductionRecordDetailComBorderRespDto.getUserFace());//SimpleFieldAssign//sourceId:1546478_1
                implementFullSceneTwoPersonConversationComReqDto.setNameOfReceive(queryInductionRecordDetailComBorderRespDto.getIdCardName());//SimpleFieldAssign//sourceId:1546479_1
                implementFullSceneTwoPersonConversationComReqDto.setReceiveOriginalRoleMemberId(queryInductionRecordDetailComBorderRespDto.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1546480_1
                implementFullSceneTwoPersonConversationComReqDto.setReceiveUserId(queryInductionRecordDetailComBorderRespDto.getUserId());//SimpleFieldAssign//sourceId:1546481_1
                implementFullSceneTwoPersonConversationComReqDto.setRoleMemberCode(queryInductionRecordDetailComBorderRespDto.getRoleMemberCode());//SimpleFieldAssign//sourceId:1546496_1
                implementFullSceneTwoPersonConversationComReqDto.setPhone(queryInductionRecordDetailComBorderRespDto.getPhone());//SimpleFieldAssign//sourceId:1546497_1
                implementFullSceneTwoPersonConversationComReqDto.setReceiveSpaceId(queryInductionRecordDetailComBorderRespDto.getSpaceId());//SimpleFieldAssign//sourceId:1546482_1
                implementFullSceneTwoPersonConversationComReqDto.setReceiveAppId(queryInductionRecordDetailComBorderRespDto.getAppId());//SimpleFieldAssign//sourceId:1546483_1
            }

            /*D2执行全场景两人会话(公共)[8260]   */
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getUseChannelMethod(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-使用通道方式不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMessagePromptType(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-消息提示类型不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getBorcScene(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-toB或toC场景不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMessageLocationCode(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-消息位置标识不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMsgChannelClassCode(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-消息使用通道类别不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getPlatformReplace(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-是否平台代操作不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getChannelTypeCode(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道类型编码不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMessageTemplateCode(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-消息模板标识不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getChannelName(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道名称不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getChannelLogo(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道缩略图地址不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getNewTableTypeCode(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道归属主体内容类型编码不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getNewEntityId(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道归属主体内容ID不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getSurfaceCode(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-归属内容类型编码不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getEntityId(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-归属内容ID不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getChannelSpaceId(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道归属空间ID不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getChannelAppId(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道归属联盟应用ID不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getHandleType(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-处理类型不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMessageContent(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-消息内容不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMessageImportantLevel(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-消息重要紧急度层级不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getIsAssistant(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方是否助手不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMessageRole(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方角色不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getSenderOriginalRoleMemberId(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方身份人员ID不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getSenderUserId(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方账号ID不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getNameOfSender(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方姓名不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getSenderProfilePictureAddress(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方头像地址不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getSenderSpaceId(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方空间ID不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getSenderAppId(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方联盟应用ID不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getReceiveProfilePictureAddress(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-接收方头像地址不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getNameOfReceive(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-接收方姓名不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getReceiveOriginalRoleMemberId(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-接收方身份人员ID不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getReceiveUserId(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-接收方账号ID不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getReceiveSpaceId(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-接收方空间ID不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getReceiveAppId(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-接收方联盟应用ID不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getComNumField(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通用数值字段（整数型）不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getOperateTime(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-操作时间不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getFirstFieldName(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-第一个字段字段名不能为空", false);
            Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getFirstFieldValue(), "D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-第一个字段字段值不能为空", false);
            implementFullSceneTwoPersonConversationComRespDto = fwCompMessageClient.implementFullSceneTwoPersonConversationCom(implementFullSceneTwoPersonConversationComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;


        }

        ImplementPrefabricateContentSendTwoPersonConvMsgComRespDto retData = new ImplementPrefabricateContentSendTwoPersonConvMsgComRespDto();


        return retData;
    }
    //
}
